const classnetColarEmail::SmtpPipeActorsys::Obj concurrent::Actor netColarEmail::SmtpPipeActorRead from one stream and pipe into another Pass the data to the consumersbufSizeconst Int bufSize := 10000makenew make(ActorPool pool)receivevirtual override Obj? receive(Obj? msg)