Uses of Interface
com.forgerock.reactive.Stream

Packages that use Stream

Package	Description
com.forgerock.opendj.grizzly	Classes implementing Grizzly transport provider.
com.forgerock.reactive	Provides asynchronous stream processing with non-blocking back pressure.
org.forgerock.opendj.grizzly	Provides an implementation of a transport provider using Grizzly as transport.
org.forgerock.opendj.ldap	Classes and interfaces for core types including connections, entries, and attributes.
org.forgerock.opendj.ldap.spi	Interfaces and classes for service providers.
org.forgerock.opendj.reactive	Classes implementing a Grizzly based ConnectionHandler using reactive api.

Uses of Stream in com.forgerock.opendj.grizzly

Method parameters in com.forgerock.opendj.grizzly with type arguments of type Stream

Modifier and Type	Method	Description
LDAPListenerImpl	GrizzlyTransportProvider.getLDAPListener(Set<InetSocketAddress> addresses, org.forgerock.util.Function<LDAPClientContext,ReactiveHandler<LDAPClientContext,LdapMessages.LdapRequestEnvelope,Stream<Response>>,LdapException> factory, org.forgerock.util.Options options)

Uses of Stream in com.forgerock.reactive

Methods in com.forgerock.reactive that return Stream

Modifier and Type	Method	Description
static <V> Stream<V>	RxJavaStreams.emptyStream()	Create a new empty Stream.
<O> Stream<O>	Stream.flatMap(org.forgerock.util.Function<? super V,? extends org.reactivestreams.Publisher<? extends O>,Exception> function, int maxConcurrency)	Transforms each data emitted by this stream into a new stream of data.
Stream<Response>	ServerConnectionFactoryAdapter.ServerConnectionAdapter.handle(LDAPClientContext context, LdapMessages.LdapRequestEnvelope request)
<O> Stream<O>	Stream.map(org.forgerock.util.Function<V,O,Exception> function)	Transforms the data emitted by this stream.
Stream<V>	Stream.onComplete(Action onComplete)	Invokes the on complete Action when this stream is completed.
Stream<V>	Stream.onError(Consumer<Throwable> onError)	Invokes the on error Consumer when an error occurs on this stream.
Stream<V>	Stream.onErrorResumeWith(org.forgerock.util.Function<Throwable,org.reactivestreams.Publisher<V>,Exception> function)	When an error occurs in this stream, continue the processing with the new Stream provided by the function.
Stream<V>	Stream.onNext(Consumer<V> onNext)	Invokes the on next Consumer when this stream emits a value.
static <V> Stream<V>	RxJavaStreams.streamError(Throwable error)	Create a new Stream composed only of the given error.
static <V> Stream<V>	RxJavaStreams.streamFrom(V value)	Create a new Stream composed only of the given value.
static <V> Stream<V>	RxJavaStreams.streamFromPublisher(org.reactivestreams.Publisher<V> publisher)	Create a new Stream from the given Publisher.
Stream<V>	Single.toStream()	Transform this Single into a Stream.

Methods in com.forgerock.reactive that return types with arguments of type Stream

Modifier and Type	Method	Description
ReactiveHandler<LDAPClientContext,LdapMessages.LdapRequestEnvelope,Stream<Response>>	ServerConnectionFactoryAdapter.apply(LDAPClientContext clientContext)	Deprecated.

Uses of Stream in org.forgerock.opendj.grizzly

Constructor parameters in org.forgerock.opendj.grizzly with type arguments of type Stream

Constructor	Description
GrizzlyLDAPListener(Set<InetSocketAddress> addresses, org.forgerock.util.Function<LDAPClientContext,ReactiveHandler<LDAPClientContext,LdapMessages.LdapRequestEnvelope,Stream<Response>>,LdapException> requestHandlerFactory, org.forgerock.util.Options options, org.glassfish.grizzly.nio.transport.TCPNIOTransport transport)	Creates a new LDAP listener implementation which will listen for LDAP client connections using the provided address, connection options and provided TCP transport.
GrizzlyLDAPListener(Set<InetSocketAddress> addresses, org.forgerock.util.Options options, org.forgerock.util.Function<LDAPClientContext,ReactiveHandler<LDAPClientContext,LdapMessages.LdapRequestEnvelope,Stream<Response>>,LdapException> requestHandlerFactory)	Creates a new LDAP listener implementation which will listen for LDAP client connections using the provided address and connection options.

Uses of Stream in org.forgerock.opendj.ldap

Constructor parameters in org.forgerock.opendj.ldap with type arguments of type Stream

Constructor	Description
LDAPListener(int port, org.forgerock.util.Function<LDAPClientContext,ReactiveHandler<LDAPClientContext,LdapMessages.LdapRequestEnvelope,Stream<Response>>,LdapException> factory)	Creates a new LDAP listener implementation which will listen for LDAP client connections at the provided address.
LDAPListener(int port, org.forgerock.util.Function<LDAPClientContext,ReactiveHandler<LDAPClientContext,LdapMessages.LdapRequestEnvelope,Stream<Response>>,LdapException> factory, org.forgerock.util.Options options)	Creates a new LDAP listener implementation which will listen for LDAP client connections at the provided address.
LDAPListener(String host, int port, org.forgerock.util.Function<LDAPClientContext,ReactiveHandler<LDAPClientContext,LdapMessages.LdapRequestEnvelope,Stream<Response>>,LdapException> factory)	Creates a new LDAP listener implementation which will listen for LDAP client connections at the provided address.
LDAPListener(String host, int port, org.forgerock.util.Function<LDAPClientContext,ReactiveHandler<LDAPClientContext,LdapMessages.LdapRequestEnvelope,Stream<Response>>,LdapException> factory, org.forgerock.util.Options options)	Creates a new LDAP listener implementation which will listen for LDAP client connections at the provided address.
LDAPListener(Set<InetSocketAddress> addresses, org.forgerock.util.Function<LDAPClientContext,ReactiveHandler<LDAPClientContext,LdapMessages.LdapRequestEnvelope,Stream<Response>>,LdapException> factory)	Creates a new LDAP listener implementation which will listen for LDAP client connections at the provided address.
LDAPListener(Set<InetSocketAddress> addresses, org.forgerock.util.Function<LDAPClientContext,ReactiveHandler<LDAPClientContext,LdapMessages.LdapRequestEnvelope,Stream<Response>>,LdapException> factory, org.forgerock.util.Options options)	Creates a new LDAP listener implementation which will listen for LDAP client connections at the provided address.

Uses of Stream in org.forgerock.opendj.ldap.spi

Method parameters in org.forgerock.opendj.ldap.spi with type arguments of type Stream

Modifier and Type	Method	Description
LDAPListenerImpl	TransportProvider.getLDAPListener(Set<InetSocketAddress> addresses, org.forgerock.util.Function<LDAPClientContext,ReactiveHandler<LDAPClientContext,LdapMessages.LdapRequestEnvelope,Stream<Response>>,LdapException> factory, org.forgerock.util.Options options)	Returns an implementation of LDAPListener.

Uses of Stream in org.forgerock.opendj.reactive

Methods in org.forgerock.opendj.reactive that return Stream

Modifier and Type	Method	Description
Stream<Response>	LDAPClientConnection2.handle(QueueingStrategy queueingStrategy, LdapMessages.LdapRequestEnvelope message)	Processes the provided LDAP message read from the client and takes whatever action is appropriate.