@Test void check() { SUT.check(o -> true); assertThat(SUT.commands, hasSize(1)); assertThat(SUT.commands.getLast().get(), notNullValue()); }
@Override public ConversationContext.SendRequestContext<T> check(Predicate<T> checker) { commands.addLast(Either.right(checker)); return this; }
DefaultSendRequestContext implements ConversationContext.SendRequestContext<T> { @Override public ConversationContext.SendRequestContext<T> check(Predicate<T> checker) { commands.addLast(Either.right(checker)); return this; } }
DefaultSendRequestContext implements ConversationContext.SendRequestContext<T> { @Override public ConversationContext.SendRequestContext<T> check(Predicate<T> checker) { commands.addLast(Either.right(checker)); return this; } DefaultSendRequestContext(Consumer<HandlerRegistration> finisher, T request, ConversationContext<T> context); protected  DefaultSendRequestContext(Deque<Either<Function<?, ?>, Predicate<?>>> commands, Duration timeout, Consumer<HandlerRegistration> finisher, Object request, ConversationContext<?> context, Class<?> expectClazz, Consumer<?> packetConsumer, Consumer<TimeoutException> onTimeoutConsumer, BiConsumer<?, ? extends Throwable> errorConsumer); }
DefaultSendRequestContext implements ConversationContext.SendRequestContext<T> { @Override public ConversationContext.SendRequestContext<T> check(Predicate<T> checker) { commands.addLast(Either.right(checker)); return this; } DefaultSendRequestContext(Consumer<HandlerRegistration> finisher, T request, ConversationContext<T> context); protected  DefaultSendRequestContext(Deque<Either<Function<?, ?>, Predicate<?>>> commands, Duration timeout, Consumer<HandlerRegistration> finisher, Object request, ConversationContext<?> context, Class<?> expectClazz, Consumer<?> packetConsumer, Consumer<TimeoutException> onTimeoutConsumer, BiConsumer<?, ? extends Throwable> errorConsumer); @Override ConversationContext.SendRequestContext<T> expectResponse(Class<T> clazz, Duration timeout); @Override ConversationContext.SendRequestContext<T> check(Predicate<T> checker); @Override DefaultContextHandler handle(Consumer<T> packetConsumer); @Override ConversationContext.SendRequestContext<T> onTimeout(Consumer<TimeoutException> onTimeoutConsumer); @Override ConversationContext.SendRequestContext<T> onError(BiConsumer<T, E> errorConsumer); @Override ConversationContext.SendRequestContext<R> unwrap(Function<T, R> unwrapper); @Override ConversationContext.SendRequestContext<R> only(Class<R> clazz); }
DefaultSendRequestContext implements ConversationContext.SendRequestContext<T> { @Override public ConversationContext.SendRequestContext<T> check(Predicate<T> checker) { commands.addLast(Either.right(checker)); return this; } DefaultSendRequestContext(Consumer<HandlerRegistration> finisher, T request, ConversationContext<T> context); protected  DefaultSendRequestContext(Deque<Either<Function<?, ?>, Predicate<?>>> commands, Duration timeout, Consumer<HandlerRegistration> finisher, Object request, ConversationContext<?> context, Class<?> expectClazz, Consumer<?> packetConsumer, Consumer<TimeoutException> onTimeoutConsumer, BiConsumer<?, ? extends Throwable> errorConsumer); @Override ConversationContext.SendRequestContext<T> expectResponse(Class<T> clazz, Duration timeout); @Override ConversationContext.SendRequestContext<T> check(Predicate<T> checker); @Override DefaultContextHandler handle(Consumer<T> packetConsumer); @Override ConversationContext.SendRequestContext<T> onTimeout(Consumer<TimeoutException> onTimeoutConsumer); @Override ConversationContext.SendRequestContext<T> onError(BiConsumer<T, E> errorConsumer); @Override ConversationContext.SendRequestContext<R> unwrap(Function<T, R> unwrapper); @Override ConversationContext.SendRequestContext<R> only(Class<R> clazz);  }