closes the stream object associated with the stream having the given index , if any , removing it from the map , logging any errors that occur during closure , and unblocking any in-progress calls to waitfor for that stream . if no such stream exists within this map , then this function has no effect . concode_field_sep ConcurrentMap<String,InterceptedStream<T>> streams concode_elem_sep long STREAM_WAIT_TIMEOUT concode_elem_sep Logger logger concode_field_sep InterceptedStream<T> get concode_elem_sep void closeAll concode_elem_sep void waitFor concode_elem_sep void put
InterceptedStream < T > function ( String arg0 ) { InterceptedStream < T > loc0 = streams . remove ( arg0 ) ; if ( loc0 == null ) return null ; close ( loc0 . getStream ( ) ) ; return loc0 ; }