org.forgerock.opendj.ldap

Class Utils

java.lang.Object

org.forgerock.opendj.ldap.Utils

public final class Utils
extends Object

This class provides utility functions.

Method Summary

Modifier and Type	Method and Description
static <C extends Closeable,T> io.reactivex.Flowable<T>	tryWith(io.reactivex.Single<C> closeable, io.reactivex.functions.Function<? super C,io.reactivex.Flowable<T>> mapper) Constructs a Flowable based upon a given Closeable and a Function mapper.
static <C extends Closeable,T> io.reactivex.Single<T>	tryWithSingle(io.reactivex.Single<C> closeable, io.reactivex.functions.Function<? super C,io.reactivex.Single<T>> mapper) Constructs a Single based upon a given Closeable and a Function mapper.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

tryWith

public static <C extends Closeable,T> io.reactivex.Flowable<T> tryWith(io.reactivex.Single<C> closeable,
                                                                       io.reactivex.functions.Function<? super C,io.reactivex.Flowable<T>> mapper)

Constructs a Flowable based upon a given Closeable and a Function mapper.

The given Closeable is automatically closed wheneveronComplete or onError or Subscription.cancel() is invoked.

This method is similar to the try-with-resources of Java 7 that closes resources at the end of the statement.

Below an example of usage: when the subscription is complete, canceled or terminates with an error, the socket is automatically closed.

 
  Single<LdapClientSocket> ldapSocket = ...
  tryWith(ldapSocket, socket -> socket.search(request)).subscribe(this::handleResponse, this::handleException)
 
 

Type Parameters:

C - Any element type that extends Closeable

T - The element type of the generated Flowable

Parameters:

closeable - The Single that encapsulates the Closeable

mapper - A factory function to create a Flowable based upon the given Closeable

Returns:

The Flowable based upon the given Closeable

See Also:

Flowable, Closeable

tryWithSingle

public static <C extends Closeable,T> io.reactivex.Single<T> tryWithSingle(io.reactivex.Single<C> closeable,
                                                                           io.reactivex.functions.Function<? super C,io.reactivex.Single<T>> mapper)

Constructs a Single based upon a given Closeable and a Function mapper.

The given Closeable is automatically closed whenever onComplete or onError or Subscription.cancel() is invoked.

This method is similar to the try-with-resources of Java 7 that closes resources at the end of the statement.

Below an example of usage: when the subscription is complete, canceled or terminates with an error, the socket is automatically closed.

 
  Single<LdapClientSocket> ldapSocket = ...
  tryWithSingle(ldapSocket, socket -> socket.searchSingleEntry(request))
      .subscribe(this::handleResponse, this::handleException)
 
 

Type Parameters:

C - Any element type that extends Closeable

T - The element type of the generated Single

Parameters:

closeable - The Single that encapsulates the Closeable

mapper - A factory function to create a Single based upon the given Closeable

Returns:

The Single based upon the given Closeable

See Also:

Single, Closeable