osmo-st-network/IPAMuxer.st

"Copyright Header"

Object subclass: IPADemuxer [
    | socket |

    IPADemuxer class >> initOn: aSocket [
	^ (self new)
	    socket: aSocket;
	    yourself.
    ]

    next [
	"Return a tuple of stream and bytearray"

	| size stream data |

	size := socket nextUshort swap16.
	stream := socket nextByte.
	data := socket next: size.

	^ Array with: stream with: data.
    ]

    socket: aSocket [
	socket := aSocket.
    ]
]

Object subclass: IPAMuxer [
    | socket |

    IPAMuxer class >> initOn: aSocket [
	^ (self new)
	    socket: aSocket;
	    yourself.
    ]

    prepareNext: aData with: aStream [
	"Write the data onto the stream"
	| msg |

	aData size > 65536
	    ifTrue: [
                self logError: 'Too much data' area: #ipa.
	        self error: 'Too much data'.
	].

	msg := MessageBuffer new.

	"put the size in ntohs"
	msg putLen16: aData size.
	msg putByte: aStream.
	msg putByteArray: aData.

	^ msg asByteArray.
    ]

    nextPut: aData with: aStream [
	socket nextPut: (self prepareNext: aData with: aStream).
    ]

    socket: aSocket [
	socket := aSocket.
    ]
]