Skip to content

Instantly share code, notes, and snippets.

View kadyana's full-sized avatar

Anatoly Kadyshev kadyana

  • Deutsche Bank
  • Moscow, Russia
View GitHub Profile
@kadyana
kadyana / gist:17518c64584149db2432
Created October 11, 2015 18:46
Server and client Aeron statistics
Server stats:
0: 96 - Bytes sent
1: 6,568 - Bytes received
2: 0 - Failed offers to ReceiverProxy
3: 0 - Failed offers to SenderProxy
4: 0 - Failed offers to DriverConductorProxy
5: 0 - NAKs sent
6: 0 - NAKs received
7: 147 - SMs sent
8: 145 - SMs received
def content = client.get('/test123') { req ->
//prepare content-type
req.header('Content-Type', 'text/plain')
//return a producing stream to send some data along the request
Streams
.just("Hello")
.log('client-send')
}.flatMap { replies ->