fn recreate_document_channel(&mut self) -> OperationReceiver {
        let (document_sender, document_receiver): (OperationSender, OperationReceiver) =
            channel::bounded(PIPELINE_MAX_SIZE_IN_DOCS);
        mem::replace(&mut self.operation_sender, document_sender);
        mem::replace(&mut self.operation_receiver, document_receiver)
    }
/// Closes the current document channel send.
/// and replace all the channels by new ones.
///
/// The current workers will keep on indexing
/// the pending document and stop
/// when no documents are remaining.
///
/// Returns the former segment_ready channel.
Closes the current document channel send.
and replace all the channels by new ones.

The current workers will keep on indexing
the pending document and stop
when no documents are remaining.

Returns the former segment_ready channel.
Closes the current document channel send . and replace all the channels by new ones . The current workers will keep on indexing the pending document and stop when no documents are remaining . Returns the former segment_ready channel .
fn recreate_document_channel(&mut self) -> OperationReceiver {
        let (document_sender, document_receiver): (OperationSender, OperationReceiver) =
            channel::bounded(PIPELINE_MAX_SIZE_IN_DOCS);
        mem::replace(&mut self.operation_sender, document_sender);
        mem::replace(&mut self.operation_receiver, document_receiver)
    }
fn recreate_document_channel ( & mut self ) -> OperationReceiver { let ( document_sender , document_receiver ) : ( OperationSender , OperationReceiver ) = channel :: bounded ( PIPELINE_MAX_SIZE_IN_DOCS ) ; mem :: replace ( & mut self . operation_sender , document_sender ) ; mem :: replace ( & mut self . operation_receiver , document_receiver ) }
Closes the current document channel send.
Closes the current document channel send .
&mut self
&mut self