Pipe Stream into parser

[thejmazz]

[thejmazz]

Using Highland.pipeline() for this

[thejmazz]

Reopening to now handle the ndjsona and object stream cases

[thejmazz]

Eh, close this again, can be for 0.2.0