public CompletableFuture < Void > close ( ) { for ( OperationAttempt attempt : new ArrayList <> ( attempts . values ( ) ) ) { attempt . fail ( new ClosedSessionException ( "session closed" ) ) ; } attempts . clear ( ) ; return CompletableFuture . completedFuture ( null ) ; }
Closes the submitter .