def METHOD_NAME(self, channel, client_thread):
    handler = GrpcHandler(channel=channel)
    flushed = client_thread.submit(
        handler.get_flush_all_state, flush_all_ts=100)
    (invocation_metadata, request, rpc) = (
        channel.take_unary_unary(descriptor.methods_by_name['GetFlushAllState']))
    rpc.send_initial_metadata(())
    expected_result = milvus_pb2.GetFlushStateResponse(
        status=common_pb2.Status(error_code=common_pb2.Success),
        flushed=True,
    )
    rpc.terminate(expected_result, (), grpc.StatusCode.OK, '')
    assert flushed.result() is True