Page History

    private fun onProcessNumber(command: ProcessNumber): Behavior<GraphCommand> {
        context.log.info("Received ProcessNumber command with number: ${command.number} - ${context.self.path().name()}")
        Source.single(command.number)
            .via(operation)
            .buffer(1000, OverflowStrategy.dropHead())
            .throttle(10, Duration.ofSeconds(1))
            .runWith(Sink.foreach { result -> command.replyTo.tell(ProcessedNumber(result)) }, materializer)
        return this
    }

    @Test
    fun testProcessNumberAdd() {
        val probe: TestProbe<GraphCommand> = testKit.createTestProbe()
        val graphActor: ActorRef<GraphCommand> = testKit.spawn(GraphActor.create())

        graphActor.tell(ProcessNumber(5, probe.ref))
        val response = probe.receiveMessage() as ProcessedNumber
        assertEquals(6, response.result)
    }