### Question:
PlatformService extends PlatformServiceGrpc.PlatformServiceImplBase implements AxonServerClientService { public void onInboundInstruction(RequestCase requestCase, InstructionConsumer consumer) { Deque<InstructionConsumer> consumers = handlers.computeIfAbsent(requestCase, rc -> new ArrayDeque<>()); consumers.add(consumer); } PlatformService(Topology topology,
                           ContextProvider contextProvider,
                           ClientIdRegistry clientIdRegistry,
                           ApplicationEventPublisher eventPublisher,
                           @Qualifier("platformInstructionAckSource")
                                   InstructionAckSource<PlatformOutboundInstruction> instructionAckSource); @Override void getPlatformServer(ClientIdentification request, StreamObserver<PlatformInfo> responseObserver); @Override StreamObserver<PlatformInboundInstruction> openStream(
            StreamObserver<PlatformOutboundInstruction> responseObserver); boolean requestReconnect(ClientComponent clientName); boolean requestReconnect(String clientId); void sendToAllClients(PlatformOutboundInstruction instruction); void sendToClientStreamId(String clientStreamId, PlatformOutboundInstruction instruction); void sendToClient(String context, String clientId, PlatformOutboundInstruction instruction); @EventListener void on(PauseEventProcessorRequest evt); @EventListener void on(StartEventProcessorRequest evt); @EventListener void on(ApplicationDisconnected event); void onInboundInstruction(RequestCase requestCase, InstructionConsumer consumer); @EventListener void on(ProcessorStatusRequest event); @EventListener void on(ApplicationInactivityTimeout evt); Set<ClientComponent> getConnectedClients(); void requestReconnectForContext(String context);  }### Answer:
@Test public void onInboundInstruction() { AtomicBoolean eventProcessorInfoReceived = new AtomicBoolean(); platformService.onInboundInstruction(PlatformInboundInstruction.RequestCase.EVENT_PROCESSOR_INFO, (client, instruction) -> eventProcessorInfoReceived.set(true)); StreamObserver<PlatformInboundInstruction> clientStreamObserver = platformService .openStream(new FakeStreamObserver<>()); clientStreamObserver.onNext(PlatformInboundInstruction.newBuilder() .setRegister(ClientIdentification.newBuilder() .setClientId( "MergeClient") .setComponentName( "component") ).build()); clientStreamObserver.onNext(PlatformInboundInstruction.newBuilder().setEventProcessorInfo(EventProcessorInfo .getDefaultInstance()) .build()); assertTrue(eventProcessorInfoReceived.get()); }