Support failing a running stream from outside (expose GraphOps.failGraph in FutureStream)
Added tests for failing graphs
Rename some classes for consistency