public List < PendingEvent > refreshSegmentEventWriters ( Consumer < Segment > segmentSealedCallBack ) { log . info ( "Refreshing segments for stream {}" , stream ) ; return updateSegments ( Futures . getAndHandleExceptions ( controller . getCurrentSegments ( stream . getScope ( ) , stream . getStreamName ( ) ) , RuntimeException :: new ) , segmentSealedCallBack ) ; }
Refresh the latest list of segments in the given stream .