import { Duplex } from "stream" ; import { ExpandedDuplexTransportConfiguration } from "../../config/expanded" ; import { Transport } from "./transport" ; export class DuplexTransport implements Transport { public readonly stream : Duplex ; public constructor ( config ) { this . stream = config . stream ( ) ; } public connect ( connectionListener ? ) { if ( connectionListener != null ) { setImmediate ( connectionListener ) ; } } }