import { Streamable , TransformApp } from "@scramjet/types" ; import { StringStream } from "scramjet" ; import { PassThrough } from "stream" ; const mod = [ { requires : "names" , contentType : "application/x-ndjson" } , function ( input ) { const out = new PassThrough ( { objectMode : true } ) ; this . logger . log ( "Instance started" ) ; ( input as StringStream ) . map ( ( data ) => "Name is: " + data . name + "\n" ) . pipe ( out ) ; return out ; } ] ; export default mod ;