Function AdaptStreamToMsgCh

pkg/wshutil/wshrpcio.go:19–23

special I/O wrappers for wshrpc * terminal (wrap with OSC codes) * stream (json lines) * websocket (json packets)

(input io.Reader, output chan baseds.RpcInputChType, readCallback func())

// * websocket (json packets)

func AdaptStreamToMsgCh(input io.Reader, output chan baseds.RpcInputChType, readCallback func()) error {
	return utilfn.StreamToLines(input, func(line []byte) {
		output <- baseds.RpcInputChType{MsgBytes: line}
	}, readCallback)
}

func AdaptOutputChToStream(outputCh chan []byte, output io.Writer) error {
	drain := false