diff --git a/IPAConnection.st b/IPAConnection.st index a5d6adb..98e5f10 100644 --- a/IPAConnection.st +++ b/IPAConnection.st @@ -2,7 +2,7 @@ PackageLoader fileInPackage: 'OsmoNetwork'. Object subclass: IPAConnection [ - | socket bsc rx tx | + | socket demuxer writeQueue muxer dispatcher | @@ -14,7 +14,14 @@ is going away.'> ] socket: aSocket [ - socket := aSocket. + socket := aSocket. + writeQueue := SharedQueue new. + + demuxer := Osmo.IPADemuxer initOn: socket. + muxer := Osmo.IPAMuxer initOn: writeQueue. + + dispatcher := Osmo.IPADispatcher new. + dispatcher initialize. ] process [