| | |
| | | import org.opends.server.util.StaticUtils; |
| | | |
| | | import com.forgerock.reactive.ReactiveHandler; |
| | | import com.forgerock.reactive.Single; |
| | | import com.forgerock.reactive.Stream; |
| | | |
| | | /** |
| | |
| | | }); |
| | | return new ReactiveHandler<LDAPClientContext, LdapRawMessage, Stream<Response>>() { |
| | | @Override |
| | | public Single<Stream<Response>> handle(LDAPClientContext context, LdapRawMessage request) |
| | | public Stream<Response> handle(LDAPClientContext context, LdapRawMessage request) |
| | | throws Exception { |
| | | return conn.handle(queueingStrategy, request); |
| | | } |