Sample current pipe code on our codebase

Existing pipe code.kt

import some.jna
import some.dtos
import some.other.domainmodels

makeEncodingAndConnectingPipe(/* makes a connected pipes using Win32 CreateNamedPipe over JNA */).use { pipe -> 
  
  pipe.writeMessage(json(StartMessage))
  expect<StartAck>(pipe.readMessage())
  
  while(isBusinessLogic()){
    
    pipe.writeMessage(json(NextIteration(mapOf("x1" to 1.0, "x2" to 2.0))))
    val result = expect<IterationResults>(pipe.readMessage())
  
    val resultActual = result ?: continue
    doBusinessLogic(resultActual)
  }
  
  pipe.writeMessage(json(DoneMessage))
  expect<DoneAck>(pipe.readMessage())
}



private fun <reified T> expect(val responseText): T? where T: MessageDTO {
  //reads a value from the pipe, deserializes it, logs an error if its decodable as a T
}