Akka Stream from Resource

[alexelcu (Alexandru Nedelcu)]

M’kay this is a related question about buffering:

Akka Streams: Force just one initial Publisher#request(1), no buffering

It appears that when subscribing to a Source, I get 2 events pulled from it, even if I limit the “input” buffer to its minimum size: .withAttributes(Attributes.inputBuffer(0, 1)) Minimal sample: Source.fromPublisher(???) .mapAsync(1) { x => Future { Thread.sleep(2000) println(s"Received: $x") } } .withAttributes(Attributes.inputBuffer(0, 1)) I cannot find a way to stop the buffering. From the perspective of the Subscriber and its Subscription, this would generate: r…