Package com.forgerock.reactive

Class ServerConnectionFactoryAdapter.ServerConnectionAdapter

java.lang.Object

com.forgerock.reactive.ServerConnectionFactoryAdapter.ServerConnectionAdapter

All Implemented Interfaces:

ReactiveHandler<LDAPClientContext,LdapMessages.LdapRequestEnvelope,Stream<Response>>

Enclosing class:

ServerConnectionFactoryAdapter

public static final class ServerConnectionFactoryAdapter.ServerConnectionAdapter
extends Object
implements ReactiveHandler<LDAPClientContext,LdapMessages.LdapRequestEnvelope,Stream<Response>>

Adapt a ServerConnection to a Function compatible with TransportProvider.getLDAPListener(java.util.Set, Function, org.forgerock.util.Options).

Constructor Summary

Constructors

Constructor	Description
ServerConnectionAdapter(LDAPClientContext clientContext, DecodeOptions decodeOptions, ServerConnection<Integer> serverConnection)	Creates a new adapter.

Method Summary

Modifier and Type	Method	Description
Stream<Response>	handle(LDAPClientContext context, LdapMessages.LdapRequestEnvelope request)	Process an input given the context.

Methods inherited from class java.lang.Object

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

Constructor Detail

ServerConnectionAdapter

public ServerConnectionAdapter(LDAPClientContext clientContext,
                               DecodeOptions decodeOptions,
                               ServerConnection<Integer> serverConnection)

Creates a new adapter.

Parameters:

clientContext - The LDAPClientContext which represents the client connection

decodeOptions - The DecodeOptions to use during request deserialization

serverConnection - the ServerConnection to adapt

Method Detail

handle

public Stream<Response> handle(LDAPClientContext context,
                               LdapMessages.LdapRequestEnvelope request)
                        throws Exception

Description copied from interface: ReactiveHandler

Process an input given the context.

Specified by:

handle in interface ReactiveHandler<LDAPClientContext,LdapMessages.LdapRequestEnvelope,Stream<Response>>

Parameters:

context - Context in which the input must be processed

request - The input to process

Returns:

An output.

Throws:

Exception - if the request cannot be processed