Class DatastreamClient (2.1.0)

public abstract class DatastreamClient

Namespace

Assembly

Google.Cloud.Datastream.V1.dll

Remarks

Properties

CreateConnectionProfileOperationsClient

public virtual OperationsClient CreateConnectionProfileOperationsClient { get; }

CreatePrivateConnectionOperationsClient

public virtual OperationsClient CreatePrivateConnectionOperationsClient { get; }

CreateRouteOperationsClient

public virtual OperationsClient CreateRouteOperationsClient { get; }

CreateStreamOperationsClient

public virtual OperationsClient CreateStreamOperationsClient { get; }

DefaultEndpoint

public static string DefaultEndpoint { get; }

DefaultScopes

public static IReadOnlyList<string> DefaultScopes { get; }

DeleteConnectionProfileOperationsClient

public virtual OperationsClient DeleteConnectionProfileOperationsClient { get; }

DeletePrivateConnectionOperationsClient

public virtual OperationsClient DeletePrivateConnectionOperationsClient { get; }

DeleteRouteOperationsClient

public virtual OperationsClient DeleteRouteOperationsClient { get; }

DeleteStreamOperationsClient

public virtual OperationsClient DeleteStreamOperationsClient { get; }

GrpcClient

public virtual Datastream.DatastreamClient GrpcClient { get; }

IAMPolicyClient

public virtual IAMPolicyClient IAMPolicyClient { get; }

LocationsClient

public virtual LocationsClient LocationsClient { get; }

ServiceMetadata

public static ServiceMetadata ServiceMetadata { get; }

UpdateConnectionProfileOperationsClient

public virtual OperationsClient UpdateConnectionProfileOperationsClient { get; }

UpdateStreamOperationsClient

public virtual OperationsClient UpdateStreamOperationsClient { get; }

Methods

Create()

public static DatastreamClient Create()

CreateAsync(CancellationToken)

public static Task<DatastreamClient> CreateAsync(CancellationToken cancellationToken = default(CancellationToken))

CreateConnectionProfile(LocationName, ConnectionProfile, String, CallSettings)

public virtual Operation<ConnectionProfile, OperationMetadata> CreateConnectionProfile(LocationName parent, ConnectionProfile connectionProfile, string connectionProfileId, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
ConnectionProfile connectionProfile = new ConnectionProfile();
string connectionProfileId = "";
// Make the request
Operation<ConnectionProfile, OperationMetadata> response = datastreamClient.CreateConnectionProfile(parent, connectionProfile, connectionProfileId);

// Poll until the returned long-running operation is complete
Operation<ConnectionProfile, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
ConnectionProfile result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<ConnectionProfile, OperationMetadata> retrievedResponse = datastreamClient.PollOnceCreateConnectionProfile(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    ConnectionProfile retrievedResult = retrievedResponse.Result;
}

CreateConnectionProfile(CreateConnectionProfileRequest, CallSettings)

public virtual Operation<ConnectionProfile, OperationMetadata> CreateConnectionProfile(CreateConnectionProfileRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
CreateConnectionProfileRequest request = new CreateConnectionProfileRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
    ConnectionProfileId = "",
    ConnectionProfile = new ConnectionProfile(),
    RequestId = "",
    ValidateOnly = false,
    Force = false,
};
// Make the request
Operation<ConnectionProfile, OperationMetadata> response = datastreamClient.CreateConnectionProfile(request);

// Poll until the returned long-running operation is complete
Operation<ConnectionProfile, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
ConnectionProfile result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<ConnectionProfile, OperationMetadata> retrievedResponse = datastreamClient.PollOnceCreateConnectionProfile(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    ConnectionProfile retrievedResult = retrievedResponse.Result;
}

CreateConnectionProfile(String, ConnectionProfile, String, CallSettings)

public virtual Operation<ConnectionProfile, OperationMetadata> CreateConnectionProfile(string parent, ConnectionProfile connectionProfile, string connectionProfileId, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
ConnectionProfile connectionProfile = new ConnectionProfile();
string connectionProfileId = "";
// Make the request
Operation<ConnectionProfile, OperationMetadata> response = datastreamClient.CreateConnectionProfile(parent, connectionProfile, connectionProfileId);

// Poll until the returned long-running operation is complete
Operation<ConnectionProfile, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
ConnectionProfile result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<ConnectionProfile, OperationMetadata> retrievedResponse = datastreamClient.PollOnceCreateConnectionProfile(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    ConnectionProfile retrievedResult = retrievedResponse.Result;
}

CreateConnectionProfileAsync(LocationName, ConnectionProfile, String, CallSettings)

public virtual Task<Operation<ConnectionProfile, OperationMetadata>> CreateConnectionProfileAsync(LocationName parent, ConnectionProfile connectionProfile, string connectionProfileId, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
ConnectionProfile connectionProfile = new ConnectionProfile();
string connectionProfileId = "";
// Make the request
Operation<ConnectionProfile, OperationMetadata> response = await datastreamClient.CreateConnectionProfileAsync(parent, connectionProfile, connectionProfileId);

// Poll until the returned long-running operation is complete
Operation<ConnectionProfile, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
ConnectionProfile result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<ConnectionProfile, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateConnectionProfileAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    ConnectionProfile retrievedResult = retrievedResponse.Result;
}

CreateConnectionProfileAsync(LocationName, ConnectionProfile, String, CancellationToken)

public virtual Task<Operation<ConnectionProfile, OperationMetadata>> CreateConnectionProfileAsync(LocationName parent, ConnectionProfile connectionProfile, string connectionProfileId, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
ConnectionProfile connectionProfile = new ConnectionProfile();
string connectionProfileId = "";
// Make the request
Operation<ConnectionProfile, OperationMetadata> response = await datastreamClient.CreateConnectionProfileAsync(parent, connectionProfile, connectionProfileId);

// Poll until the returned long-running operation is complete
Operation<ConnectionProfile, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
ConnectionProfile result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<ConnectionProfile, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateConnectionProfileAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    ConnectionProfile retrievedResult = retrievedResponse.Result;
}

CreateConnectionProfileAsync(CreateConnectionProfileRequest, CallSettings)

public virtual Task<Operation<ConnectionProfile, OperationMetadata>> CreateConnectionProfileAsync(CreateConnectionProfileRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
CreateConnectionProfileRequest request = new CreateConnectionProfileRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
    ConnectionProfileId = "",
    ConnectionProfile = new ConnectionProfile(),
    RequestId = "",
    ValidateOnly = false,
    Force = false,
};
// Make the request
Operation<ConnectionProfile, OperationMetadata> response = await datastreamClient.CreateConnectionProfileAsync(request);

// Poll until the returned long-running operation is complete
Operation<ConnectionProfile, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
ConnectionProfile result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<ConnectionProfile, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateConnectionProfileAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    ConnectionProfile retrievedResult = retrievedResponse.Result;
}

CreateConnectionProfileAsync(CreateConnectionProfileRequest, CancellationToken)

public virtual Task<Operation<ConnectionProfile, OperationMetadata>> CreateConnectionProfileAsync(CreateConnectionProfileRequest request, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
CreateConnectionProfileRequest request = new CreateConnectionProfileRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
    ConnectionProfileId = "",
    ConnectionProfile = new ConnectionProfile(),
    RequestId = "",
    ValidateOnly = false,
    Force = false,
};
// Make the request
Operation<ConnectionProfile, OperationMetadata> response = await datastreamClient.CreateConnectionProfileAsync(request);

// Poll until the returned long-running operation is complete
Operation<ConnectionProfile, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
ConnectionProfile result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<ConnectionProfile, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateConnectionProfileAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    ConnectionProfile retrievedResult = retrievedResponse.Result;
}

CreateConnectionProfileAsync(String, ConnectionProfile, String, CallSettings)

public virtual Task<Operation<ConnectionProfile, OperationMetadata>> CreateConnectionProfileAsync(string parent, ConnectionProfile connectionProfile, string connectionProfileId, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
ConnectionProfile connectionProfile = new ConnectionProfile();
string connectionProfileId = "";
// Make the request
Operation<ConnectionProfile, OperationMetadata> response = await datastreamClient.CreateConnectionProfileAsync(parent, connectionProfile, connectionProfileId);

// Poll until the returned long-running operation is complete
Operation<ConnectionProfile, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
ConnectionProfile result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<ConnectionProfile, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateConnectionProfileAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    ConnectionProfile retrievedResult = retrievedResponse.Result;
}

CreateConnectionProfileAsync(String, ConnectionProfile, String, CancellationToken)

public virtual Task<Operation<ConnectionProfile, OperationMetadata>> CreateConnectionProfileAsync(string parent, ConnectionProfile connectionProfile, string connectionProfileId, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
ConnectionProfile connectionProfile = new ConnectionProfile();
string connectionProfileId = "";
// Make the request
Operation<ConnectionProfile, OperationMetadata> response = await datastreamClient.CreateConnectionProfileAsync(parent, connectionProfile, connectionProfileId);

// Poll until the returned long-running operation is complete
Operation<ConnectionProfile, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
ConnectionProfile result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<ConnectionProfile, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateConnectionProfileAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    ConnectionProfile retrievedResult = retrievedResponse.Result;
}

CreatePrivateConnection(LocationName, PrivateConnection, String, CallSettings)

public virtual Operation<PrivateConnection, OperationMetadata> CreatePrivateConnection(LocationName parent, PrivateConnection privateConnection, string privateConnectionId, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
PrivateConnection privateConnection = new PrivateConnection();
string privateConnectionId = "";
// Make the request
Operation<PrivateConnection, OperationMetadata> response = datastreamClient.CreatePrivateConnection(parent, privateConnection, privateConnectionId);

// Poll until the returned long-running operation is complete
Operation<PrivateConnection, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
PrivateConnection result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<PrivateConnection, OperationMetadata> retrievedResponse = datastreamClient.PollOnceCreatePrivateConnection(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    PrivateConnection retrievedResult = retrievedResponse.Result;
}

CreatePrivateConnection(CreatePrivateConnectionRequest, CallSettings)

public virtual Operation<PrivateConnection, OperationMetadata> CreatePrivateConnection(CreatePrivateConnectionRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
CreatePrivateConnectionRequest request = new CreatePrivateConnectionRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
    PrivateConnectionId = "",
    PrivateConnection = new PrivateConnection(),
    RequestId = "",
};
// Make the request
Operation<PrivateConnection, OperationMetadata> response = datastreamClient.CreatePrivateConnection(request);

// Poll until the returned long-running operation is complete
Operation<PrivateConnection, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
PrivateConnection result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<PrivateConnection, OperationMetadata> retrievedResponse = datastreamClient.PollOnceCreatePrivateConnection(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    PrivateConnection retrievedResult = retrievedResponse.Result;
}

CreatePrivateConnection(String, PrivateConnection, String, CallSettings)

public virtual Operation<PrivateConnection, OperationMetadata> CreatePrivateConnection(string parent, PrivateConnection privateConnection, string privateConnectionId, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
PrivateConnection privateConnection = new PrivateConnection();
string privateConnectionId = "";
// Make the request
Operation<PrivateConnection, OperationMetadata> response = datastreamClient.CreatePrivateConnection(parent, privateConnection, privateConnectionId);

// Poll until the returned long-running operation is complete
Operation<PrivateConnection, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
PrivateConnection result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<PrivateConnection, OperationMetadata> retrievedResponse = datastreamClient.PollOnceCreatePrivateConnection(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    PrivateConnection retrievedResult = retrievedResponse.Result;
}

CreatePrivateConnectionAsync(LocationName, PrivateConnection, String, CallSettings)

public virtual Task<Operation<PrivateConnection, OperationMetadata>> CreatePrivateConnectionAsync(LocationName parent, PrivateConnection privateConnection, string privateConnectionId, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
PrivateConnection privateConnection = new PrivateConnection();
string privateConnectionId = "";
// Make the request
Operation<PrivateConnection, OperationMetadata> response = await datastreamClient.CreatePrivateConnectionAsync(parent, privateConnection, privateConnectionId);

// Poll until the returned long-running operation is complete
Operation<PrivateConnection, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
PrivateConnection result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<PrivateConnection, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreatePrivateConnectionAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    PrivateConnection retrievedResult = retrievedResponse.Result;
}

CreatePrivateConnectionAsync(LocationName, PrivateConnection, String, CancellationToken)

public virtual Task<Operation<PrivateConnection, OperationMetadata>> CreatePrivateConnectionAsync(LocationName parent, PrivateConnection privateConnection, string privateConnectionId, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
PrivateConnection privateConnection = new PrivateConnection();
string privateConnectionId = "";
// Make the request
Operation<PrivateConnection, OperationMetadata> response = await datastreamClient.CreatePrivateConnectionAsync(parent, privateConnection, privateConnectionId);

// Poll until the returned long-running operation is complete
Operation<PrivateConnection, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
PrivateConnection result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<PrivateConnection, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreatePrivateConnectionAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    PrivateConnection retrievedResult = retrievedResponse.Result;
}

CreatePrivateConnectionAsync(CreatePrivateConnectionRequest, CallSettings)

public virtual Task<Operation<PrivateConnection, OperationMetadata>> CreatePrivateConnectionAsync(CreatePrivateConnectionRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
CreatePrivateConnectionRequest request = new CreatePrivateConnectionRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
    PrivateConnectionId = "",
    PrivateConnection = new PrivateConnection(),
    RequestId = "",
};
// Make the request
Operation<PrivateConnection, OperationMetadata> response = await datastreamClient.CreatePrivateConnectionAsync(request);

// Poll until the returned long-running operation is complete
Operation<PrivateConnection, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
PrivateConnection result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<PrivateConnection, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreatePrivateConnectionAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    PrivateConnection retrievedResult = retrievedResponse.Result;
}

CreatePrivateConnectionAsync(CreatePrivateConnectionRequest, CancellationToken)

public virtual Task<Operation<PrivateConnection, OperationMetadata>> CreatePrivateConnectionAsync(CreatePrivateConnectionRequest request, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
CreatePrivateConnectionRequest request = new CreatePrivateConnectionRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
    PrivateConnectionId = "",
    PrivateConnection = new PrivateConnection(),
    RequestId = "",
};
// Make the request
Operation<PrivateConnection, OperationMetadata> response = await datastreamClient.CreatePrivateConnectionAsync(request);

// Poll until the returned long-running operation is complete
Operation<PrivateConnection, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
PrivateConnection result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<PrivateConnection, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreatePrivateConnectionAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    PrivateConnection retrievedResult = retrievedResponse.Result;
}

CreatePrivateConnectionAsync(String, PrivateConnection, String, CallSettings)

public virtual Task<Operation<PrivateConnection, OperationMetadata>> CreatePrivateConnectionAsync(string parent, PrivateConnection privateConnection, string privateConnectionId, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
PrivateConnection privateConnection = new PrivateConnection();
string privateConnectionId = "";
// Make the request
Operation<PrivateConnection, OperationMetadata> response = await datastreamClient.CreatePrivateConnectionAsync(parent, privateConnection, privateConnectionId);

// Poll until the returned long-running operation is complete
Operation<PrivateConnection, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
PrivateConnection result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<PrivateConnection, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreatePrivateConnectionAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    PrivateConnection retrievedResult = retrievedResponse.Result;
}

CreatePrivateConnectionAsync(String, PrivateConnection, String, CancellationToken)

public virtual Task<Operation<PrivateConnection, OperationMetadata>> CreatePrivateConnectionAsync(string parent, PrivateConnection privateConnection, string privateConnectionId, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
PrivateConnection privateConnection = new PrivateConnection();
string privateConnectionId = "";
// Make the request
Operation<PrivateConnection, OperationMetadata> response = await datastreamClient.CreatePrivateConnectionAsync(parent, privateConnection, privateConnectionId);

// Poll until the returned long-running operation is complete
Operation<PrivateConnection, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
PrivateConnection result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<PrivateConnection, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreatePrivateConnectionAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    PrivateConnection retrievedResult = retrievedResponse.Result;
}

CreateRoute(CreateRouteRequest, CallSettings)

public virtual Operation<Route, OperationMetadata> CreateRoute(CreateRouteRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
CreateRouteRequest request = new CreateRouteRequest
{
    ParentAsPrivateConnectionName = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]"),
    RouteId = "",
    Route = new Route(),
    RequestId = "",
};
// Make the request
Operation<Route, OperationMetadata> response = datastreamClient.CreateRoute(request);

// Poll until the returned long-running operation is complete
Operation<Route, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Route result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Route, OperationMetadata> retrievedResponse = datastreamClient.PollOnceCreateRoute(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Route retrievedResult = retrievedResponse.Result;
}

CreateRoute(PrivateConnectionName, Route, String, CallSettings)

public virtual Operation<Route, OperationMetadata> CreateRoute(PrivateConnectionName parent, Route route, string routeId, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
PrivateConnectionName parent = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
Route route = new Route();
string routeId = "";
// Make the request
Operation<Route, OperationMetadata> response = datastreamClient.CreateRoute(parent, route, routeId);

// Poll until the returned long-running operation is complete
Operation<Route, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Route result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Route, OperationMetadata> retrievedResponse = datastreamClient.PollOnceCreateRoute(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Route retrievedResult = retrievedResponse.Result;
}

CreateRoute(String, Route, String, CallSettings)

public virtual Operation<Route, OperationMetadata> CreateRoute(string parent, Route route, string routeId, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]";
Route route = new Route();
string routeId = "";
// Make the request
Operation<Route, OperationMetadata> response = datastreamClient.CreateRoute(parent, route, routeId);

// Poll until the returned long-running operation is complete
Operation<Route, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Route result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Route, OperationMetadata> retrievedResponse = datastreamClient.PollOnceCreateRoute(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Route retrievedResult = retrievedResponse.Result;
}

CreateRouteAsync(CreateRouteRequest, CallSettings)

public virtual Task<Operation<Route, OperationMetadata>> CreateRouteAsync(CreateRouteRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
CreateRouteRequest request = new CreateRouteRequest
{
    ParentAsPrivateConnectionName = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]"),
    RouteId = "",
    Route = new Route(),
    RequestId = "",
};
// Make the request
Operation<Route, OperationMetadata> response = await datastreamClient.CreateRouteAsync(request);

// Poll until the returned long-running operation is complete
Operation<Route, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Route result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Route, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateRouteAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Route retrievedResult = retrievedResponse.Result;
}

CreateRouteAsync(CreateRouteRequest, CancellationToken)

public virtual Task<Operation<Route, OperationMetadata>> CreateRouteAsync(CreateRouteRequest request, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
CreateRouteRequest request = new CreateRouteRequest
{
    ParentAsPrivateConnectionName = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]"),
    RouteId = "",
    Route = new Route(),
    RequestId = "",
};
// Make the request
Operation<Route, OperationMetadata> response = await datastreamClient.CreateRouteAsync(request);

// Poll until the returned long-running operation is complete
Operation<Route, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Route result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Route, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateRouteAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Route retrievedResult = retrievedResponse.Result;
}

CreateRouteAsync(PrivateConnectionName, Route, String, CallSettings)

public virtual Task<Operation<Route, OperationMetadata>> CreateRouteAsync(PrivateConnectionName parent, Route route, string routeId, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
PrivateConnectionName parent = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
Route route = new Route();
string routeId = "";
// Make the request
Operation<Route, OperationMetadata> response = await datastreamClient.CreateRouteAsync(parent, route, routeId);

// Poll until the returned long-running operation is complete
Operation<Route, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Route result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Route, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateRouteAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Route retrievedResult = retrievedResponse.Result;
}

CreateRouteAsync(PrivateConnectionName, Route, String, CancellationToken)

public virtual Task<Operation<Route, OperationMetadata>> CreateRouteAsync(PrivateConnectionName parent, Route route, string routeId, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
PrivateConnectionName parent = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
Route route = new Route();
string routeId = "";
// Make the request
Operation<Route, OperationMetadata> response = await datastreamClient.CreateRouteAsync(parent, route, routeId);

// Poll until the returned long-running operation is complete
Operation<Route, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Route result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Route, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateRouteAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Route retrievedResult = retrievedResponse.Result;
}

CreateRouteAsync(String, Route, String, CallSettings)

public virtual Task<Operation<Route, OperationMetadata>> CreateRouteAsync(string parent, Route route, string routeId, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]";
Route route = new Route();
string routeId = "";
// Make the request
Operation<Route, OperationMetadata> response = await datastreamClient.CreateRouteAsync(parent, route, routeId);

// Poll until the returned long-running operation is complete
Operation<Route, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Route result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Route, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateRouteAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Route retrievedResult = retrievedResponse.Result;
}

CreateRouteAsync(String, Route, String, CancellationToken)

public virtual Task<Operation<Route, OperationMetadata>> CreateRouteAsync(string parent, Route route, string routeId, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]";
Route route = new Route();
string routeId = "";
// Make the request
Operation<Route, OperationMetadata> response = await datastreamClient.CreateRouteAsync(parent, route, routeId);

// Poll until the returned long-running operation is complete
Operation<Route, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Route result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Route, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateRouteAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Route retrievedResult = retrievedResponse.Result;
}

CreateStream(LocationName, Stream, String, CallSettings)

public virtual Operation<Stream, OperationMetadata> CreateStream(LocationName parent, Stream stream, string streamId, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
Stream stream = new Stream();
string streamId = "";
// Make the request
Operation<Stream, OperationMetadata> response = datastreamClient.CreateStream(parent, stream, streamId);

// Poll until the returned long-running operation is complete
Operation<Stream, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Stream result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Stream, OperationMetadata> retrievedResponse = datastreamClient.PollOnceCreateStream(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Stream retrievedResult = retrievedResponse.Result;
}

CreateStream(CreateStreamRequest, CallSettings)

public virtual Operation<Stream, OperationMetadata> CreateStream(CreateStreamRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
CreateStreamRequest request = new CreateStreamRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
    StreamId = "",
    Stream = new Stream(),
    RequestId = "",
    ValidateOnly = false,
    Force = false,
};
// Make the request
Operation<Stream, OperationMetadata> response = datastreamClient.CreateStream(request);

// Poll until the returned long-running operation is complete
Operation<Stream, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Stream result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Stream, OperationMetadata> retrievedResponse = datastreamClient.PollOnceCreateStream(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Stream retrievedResult = retrievedResponse.Result;
}

CreateStream(String, Stream, String, CallSettings)

public virtual Operation<Stream, OperationMetadata> CreateStream(string parent, Stream stream, string streamId, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
Stream stream = new Stream();
string streamId = "";
// Make the request
Operation<Stream, OperationMetadata> response = datastreamClient.CreateStream(parent, stream, streamId);

// Poll until the returned long-running operation is complete
Operation<Stream, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Stream result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Stream, OperationMetadata> retrievedResponse = datastreamClient.PollOnceCreateStream(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Stream retrievedResult = retrievedResponse.Result;
}

CreateStreamAsync(LocationName, Stream, String, CallSettings)

public virtual Task<Operation<Stream, OperationMetadata>> CreateStreamAsync(LocationName parent, Stream stream, string streamId, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
Stream stream = new Stream();
string streamId = "";
// Make the request
Operation<Stream, OperationMetadata> response = await datastreamClient.CreateStreamAsync(parent, stream, streamId);

// Poll until the returned long-running operation is complete
Operation<Stream, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Stream result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Stream, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Stream retrievedResult = retrievedResponse.Result;
}

CreateStreamAsync(LocationName, Stream, String, CancellationToken)

public virtual Task<Operation<Stream, OperationMetadata>> CreateStreamAsync(LocationName parent, Stream stream, string streamId, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
LocationName parent = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
Stream stream = new Stream();
string streamId = "";
// Make the request
Operation<Stream, OperationMetadata> response = await datastreamClient.CreateStreamAsync(parent, stream, streamId);

// Poll until the returned long-running operation is complete
Operation<Stream, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Stream result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Stream, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Stream retrievedResult = retrievedResponse.Result;
}

CreateStreamAsync(CreateStreamRequest, CallSettings)

public virtual Task<Operation<Stream, OperationMetadata>> CreateStreamAsync(CreateStreamRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
CreateStreamRequest request = new CreateStreamRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
    StreamId = "",
    Stream = new Stream(),
    RequestId = "",
    ValidateOnly = false,
    Force = false,
};
// Make the request
Operation<Stream, OperationMetadata> response = await datastreamClient.CreateStreamAsync(request);

// Poll until the returned long-running operation is complete
Operation<Stream, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Stream result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Stream, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Stream retrievedResult = retrievedResponse.Result;
}

CreateStreamAsync(CreateStreamRequest, CancellationToken)

public virtual Task<Operation<Stream, OperationMetadata>> CreateStreamAsync(CreateStreamRequest request, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
CreateStreamRequest request = new CreateStreamRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
    StreamId = "",
    Stream = new Stream(),
    RequestId = "",
    ValidateOnly = false,
    Force = false,
};
// Make the request
Operation<Stream, OperationMetadata> response = await datastreamClient.CreateStreamAsync(request);

// Poll until the returned long-running operation is complete
Operation<Stream, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Stream result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Stream, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Stream retrievedResult = retrievedResponse.Result;
}

CreateStreamAsync(String, Stream, String, CallSettings)

public virtual Task<Operation<Stream, OperationMetadata>> CreateStreamAsync(string parent, Stream stream, string streamId, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
Stream stream = new Stream();
string streamId = "";
// Make the request
Operation<Stream, OperationMetadata> response = await datastreamClient.CreateStreamAsync(parent, stream, streamId);

// Poll until the returned long-running operation is complete
Operation<Stream, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Stream result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Stream, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Stream retrievedResult = retrievedResponse.Result;
}

CreateStreamAsync(String, Stream, String, CancellationToken)

public virtual Task<Operation<Stream, OperationMetadata>> CreateStreamAsync(string parent, Stream stream, string streamId, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string parent = "projects/[PROJECT]/locations/[LOCATION]";
Stream stream = new Stream();
string streamId = "";
// Make the request
Operation<Stream, OperationMetadata> response = await datastreamClient.CreateStreamAsync(parent, stream, streamId);

// Poll until the returned long-running operation is complete
Operation<Stream, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Stream result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Stream, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceCreateStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Stream retrievedResult = retrievedResponse.Result;
}

DeleteConnectionProfile(ConnectionProfileName, CallSettings)

public virtual Operation<Empty, OperationMetadata> DeleteConnectionProfile(ConnectionProfileName name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
ConnectionProfileName name = ConnectionProfileName.FromProjectLocationConnectionProfile("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]");
// Make the request
Operation<Empty, OperationMetadata> response = datastreamClient.DeleteConnectionProfile(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = datastreamClient.PollOnceDeleteConnectionProfile(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteConnectionProfile(DeleteConnectionProfileRequest, CallSettings)

public virtual Operation<Empty, OperationMetadata> DeleteConnectionProfile(DeleteConnectionProfileRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
DeleteConnectionProfileRequest request = new DeleteConnectionProfileRequest
{
    ConnectionProfileName = ConnectionProfileName.FromProjectLocationConnectionProfile("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]"),
    RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = datastreamClient.DeleteConnectionProfile(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = datastreamClient.PollOnceDeleteConnectionProfile(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteConnectionProfile(String, CallSettings)

public virtual Operation<Empty, OperationMetadata> DeleteConnectionProfile(string name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/connectionProfiles/[CONNECTION_PROFILE]";
// Make the request
Operation<Empty, OperationMetadata> response = datastreamClient.DeleteConnectionProfile(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = datastreamClient.PollOnceDeleteConnectionProfile(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteConnectionProfileAsync(ConnectionProfileName, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteConnectionProfileAsync(ConnectionProfileName name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
ConnectionProfileName name = ConnectionProfileName.FromProjectLocationConnectionProfile("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]");
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteConnectionProfileAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceDeleteConnectionProfileAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteConnectionProfileAsync(ConnectionProfileName, CancellationToken)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteConnectionProfileAsync(ConnectionProfileName name, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
ConnectionProfileName name = ConnectionProfileName.FromProjectLocationConnectionProfile("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]");
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteConnectionProfileAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceDeleteConnectionProfileAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteConnectionProfileAsync(DeleteConnectionProfileRequest, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteConnectionProfileAsync(DeleteConnectionProfileRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
DeleteConnectionProfileRequest request = new DeleteConnectionProfileRequest
{
    ConnectionProfileName = ConnectionProfileName.FromProjectLocationConnectionProfile("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]"),
    RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteConnectionProfileAsync(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceDeleteConnectionProfileAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteConnectionProfileAsync(DeleteConnectionProfileRequest, CancellationToken)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteConnectionProfileAsync(DeleteConnectionProfileRequest request, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
DeleteConnectionProfileRequest request = new DeleteConnectionProfileRequest
{
    ConnectionProfileName = ConnectionProfileName.FromProjectLocationConnectionProfile("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]"),
    RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteConnectionProfileAsync(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceDeleteConnectionProfileAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteConnectionProfileAsync(String, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteConnectionProfileAsync(string name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/connectionProfiles/[CONNECTION_PROFILE]";
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteConnectionProfileAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceDeleteConnectionProfileAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteConnectionProfileAsync(String, CancellationToken)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteConnectionProfileAsync(string name, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/connectionProfiles/[CONNECTION_PROFILE]";
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteConnectionProfileAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceDeleteConnectionProfileAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeletePrivateConnection(DeletePrivateConnectionRequest, CallSettings)

public virtual Operation<Empty, OperationMetadata> DeletePrivateConnection(DeletePrivateConnectionRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
DeletePrivateConnectionRequest request = new DeletePrivateConnectionRequest
{
    PrivateConnectionName = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]"),
    RequestId = "",
    Force = false,
};
// Make the request
Operation<Empty, OperationMetadata> response = datastreamClient.DeletePrivateConnection(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = datastreamClient.PollOnceDeletePrivateConnection(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeletePrivateConnection(PrivateConnectionName, CallSettings)

public virtual Operation<Empty, OperationMetadata> DeletePrivateConnection(PrivateConnectionName name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
PrivateConnectionName name = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
// Make the request
Operation<Empty, OperationMetadata> response = datastreamClient.DeletePrivateConnection(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = datastreamClient.PollOnceDeletePrivateConnection(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeletePrivateConnection(String, CallSettings)

public virtual Operation<Empty, OperationMetadata> DeletePrivateConnection(string name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]";
// Make the request
Operation<Empty, OperationMetadata> response = datastreamClient.DeletePrivateConnection(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = datastreamClient.PollOnceDeletePrivateConnection(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeletePrivateConnectionAsync(DeletePrivateConnectionRequest, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> DeletePrivateConnectionAsync(DeletePrivateConnectionRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
DeletePrivateConnectionRequest request = new DeletePrivateConnectionRequest
{
    PrivateConnectionName = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]"),
    RequestId = "",
    Force = false,
};
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeletePrivateConnectionAsync(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceDeletePrivateConnectionAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeletePrivateConnectionAsync(DeletePrivateConnectionRequest, CancellationToken)

public virtual Task<Operation<Empty, OperationMetadata>> DeletePrivateConnectionAsync(DeletePrivateConnectionRequest request, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
DeletePrivateConnectionRequest request = new DeletePrivateConnectionRequest
{
    PrivateConnectionName = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]"),
    RequestId = "",
    Force = false,
};
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeletePrivateConnectionAsync(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceDeletePrivateConnectionAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeletePrivateConnectionAsync(PrivateConnectionName, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> DeletePrivateConnectionAsync(PrivateConnectionName name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
PrivateConnectionName name = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeletePrivateConnectionAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceDeletePrivateConnectionAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeletePrivateConnectionAsync(PrivateConnectionName, CancellationToken)

public virtual Task<Operation<Empty, OperationMetadata>> DeletePrivateConnectionAsync(PrivateConnectionName name, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
PrivateConnectionName name = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeletePrivateConnectionAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceDeletePrivateConnectionAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeletePrivateConnectionAsync(String, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> DeletePrivateConnectionAsync(string name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]";
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeletePrivateConnectionAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceDeletePrivateConnectionAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeletePrivateConnectionAsync(String, CancellationToken)

public virtual Task<Operation<Empty, OperationMetadata>> DeletePrivateConnectionAsync(string name, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]";
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeletePrivateConnectionAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceDeletePrivateConnectionAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteRoute(DeleteRouteRequest, CallSettings)

public virtual Operation<Empty, OperationMetadata> DeleteRoute(DeleteRouteRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
DeleteRouteRequest request = new DeleteRouteRequest
{
    RouteName = RouteName.FromProjectLocationPrivateConnectionRoute("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]"),
    RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = datastreamClient.DeleteRoute(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = datastreamClient.PollOnceDeleteRoute(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteRoute(RouteName, CallSettings)

public virtual Operation<Empty, OperationMetadata> DeleteRoute(RouteName name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
RouteName name = RouteName.FromProjectLocationPrivateConnectionRoute("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]");
// Make the request
Operation<Empty, OperationMetadata> response = datastreamClient.DeleteRoute(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = datastreamClient.PollOnceDeleteRoute(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteRoute(String, CallSettings)

public virtual Operation<Empty, OperationMetadata> DeleteRoute(string name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]/routes/[ROUTE]";
// Make the request
Operation<Empty, OperationMetadata> response = datastreamClient.DeleteRoute(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = datastreamClient.PollOnceDeleteRoute(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteRouteAsync(DeleteRouteRequest, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteRouteAsync(DeleteRouteRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
DeleteRouteRequest request = new DeleteRouteRequest
{
    RouteName = RouteName.FromProjectLocationPrivateConnectionRoute("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]"),
    RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteRouteAsync(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceDeleteRouteAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteRouteAsync(DeleteRouteRequest, CancellationToken)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteRouteAsync(DeleteRouteRequest request, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
DeleteRouteRequest request = new DeleteRouteRequest
{
    RouteName = RouteName.FromProjectLocationPrivateConnectionRoute("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]"),
    RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteRouteAsync(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceDeleteRouteAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteRouteAsync(RouteName, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteRouteAsync(RouteName name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
RouteName name = RouteName.FromProjectLocationPrivateConnectionRoute("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]");
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteRouteAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceDeleteRouteAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteRouteAsync(RouteName, CancellationToken)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteRouteAsync(RouteName name, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
RouteName name = RouteName.FromProjectLocationPrivateConnectionRoute("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]");
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteRouteAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceDeleteRouteAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteRouteAsync(String, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteRouteAsync(string name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]/routes/[ROUTE]";
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteRouteAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceDeleteRouteAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteRouteAsync(String, CancellationToken)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteRouteAsync(string name, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]/routes/[ROUTE]";
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteRouteAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceDeleteRouteAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteStream(DeleteStreamRequest, CallSettings)

public virtual Operation<Empty, OperationMetadata> DeleteStream(DeleteStreamRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
DeleteStreamRequest request = new DeleteStreamRequest
{
    StreamName = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]"),
    RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = datastreamClient.DeleteStream(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = datastreamClient.PollOnceDeleteStream(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteStream(StreamName, CallSettings)

public virtual Operation<Empty, OperationMetadata> DeleteStream(StreamName name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
StreamName name = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]");
// Make the request
Operation<Empty, OperationMetadata> response = datastreamClient.DeleteStream(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = datastreamClient.PollOnceDeleteStream(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteStream(String, CallSettings)

public virtual Operation<Empty, OperationMetadata> DeleteStream(string name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/streams/[STREAM]";
// Make the request
Operation<Empty, OperationMetadata> response = datastreamClient.DeleteStream(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = response.PollUntilCompleted();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = datastreamClient.PollOnceDeleteStream(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteStreamAsync(DeleteStreamRequest, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteStreamAsync(DeleteStreamRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
DeleteStreamRequest request = new DeleteStreamRequest
{
    StreamName = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]"),
    RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteStreamAsync(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceDeleteStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteStreamAsync(DeleteStreamRequest, CancellationToken)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteStreamAsync(DeleteStreamRequest request, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
DeleteStreamRequest request = new DeleteStreamRequest
{
    StreamName = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]"),
    RequestId = "",
};
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteStreamAsync(request);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceDeleteStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteStreamAsync(StreamName, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteStreamAsync(StreamName name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
StreamName name = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]");
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteStreamAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceDeleteStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteStreamAsync(StreamName, CancellationToken)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteStreamAsync(StreamName name, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
StreamName name = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]");
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteStreamAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceDeleteStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteStreamAsync(String, CallSettings)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteStreamAsync(string name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/streams/[STREAM]";
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteStreamAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceDeleteStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DeleteStreamAsync(String, CancellationToken)

public virtual Task<Operation<Empty, OperationMetadata>> DeleteStreamAsync(string name, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/streams/[STREAM]";
// Make the request
Operation<Empty, OperationMetadata> response = await datastreamClient.DeleteStreamAsync(name);

// Poll until the returned long-running operation is complete
Operation<Empty, OperationMetadata> completedResponse = await response.PollUntilCompletedAsync();
// Retrieve the operation result
Empty result = completedResponse.Result;

// Or get the name of the operation
string operationName = response.Name;
// This name can be stored, then the long-running operation retrieved later by name
Operation<Empty, OperationMetadata> retrievedResponse = await datastreamClient.PollOnceDeleteStreamAsync(operationName);
// Check if the retrieved long-running operation has completed
if (retrievedResponse.IsCompleted)
{
    // If it has completed, then access the result
    Empty retrievedResult = retrievedResponse.Result;
}

DiscoverConnectionProfile(DiscoverConnectionProfileRequest, CallSettings)

public virtual DiscoverConnectionProfileResponse DiscoverConnectionProfile(DiscoverConnectionProfileRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
DiscoverConnectionProfileRequest request = new DiscoverConnectionProfileRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
    FullHierarchy = false,
    OracleRdbms = new OracleRdbms(),
    ConnectionProfile = new ConnectionProfile(),
};
// Make the request
DiscoverConnectionProfileResponse response = datastreamClient.DiscoverConnectionProfile(request);

DiscoverConnectionProfileAsync(DiscoverConnectionProfileRequest, CallSettings)

public virtual Task<DiscoverConnectionProfileResponse> DiscoverConnectionProfileAsync(DiscoverConnectionProfileRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
DiscoverConnectionProfileRequest request = new DiscoverConnectionProfileRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
    FullHierarchy = false,
    OracleRdbms = new OracleRdbms(),
    ConnectionProfile = new ConnectionProfile(),
};
// Make the request
DiscoverConnectionProfileResponse response = await datastreamClient.DiscoverConnectionProfileAsync(request);

DiscoverConnectionProfileAsync(DiscoverConnectionProfileRequest, CancellationToken)

public virtual Task<DiscoverConnectionProfileResponse> DiscoverConnectionProfileAsync(DiscoverConnectionProfileRequest request, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
DiscoverConnectionProfileRequest request = new DiscoverConnectionProfileRequest
{
    ParentAsLocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
    FullHierarchy = false,
    OracleRdbms = new OracleRdbms(),
    ConnectionProfile = new ConnectionProfile(),
};
// Make the request
DiscoverConnectionProfileResponse response = await datastreamClient.DiscoverConnectionProfileAsync(request);

FetchStaticIps(LocationName, String, Nullable<Int32>, CallSettings)

public virtual PagedEnumerable<FetchStaticIpsResponse, string> FetchStaticIps(LocationName name, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
LocationName name = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
// Make the request
PagedEnumerable<FetchStaticIpsResponse, string> response = datastreamClient.FetchStaticIps(name);

// Iterate over all response items, lazily performing RPCs as required
foreach (string item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (FetchStaticIpsResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (string item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<string> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (string item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

FetchStaticIps(FetchStaticIpsRequest, CallSettings)

public virtual PagedEnumerable<FetchStaticIpsResponse, string> FetchStaticIps(FetchStaticIpsRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
FetchStaticIpsRequest request = new FetchStaticIpsRequest
{
    LocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
};
// Make the request
PagedEnumerable<FetchStaticIpsResponse, string> response = datastreamClient.FetchStaticIps(request);

// Iterate over all response items, lazily performing RPCs as required
foreach (string item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (FetchStaticIpsResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (string item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<string> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (string item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

FetchStaticIps(String, String, Nullable<Int32>, CallSettings)

public virtual PagedEnumerable<FetchStaticIpsResponse, string> FetchStaticIps(string name, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]";
// Make the request
PagedEnumerable<FetchStaticIpsResponse, string> response = datastreamClient.FetchStaticIps(name);

// Iterate over all response items, lazily performing RPCs as required
foreach (string item in response)
{
    // Do something with each item
    Console.WriteLine(item);
}

// Or iterate over pages (of server-defined size), performing one RPC per page
foreach (FetchStaticIpsResponse page in response.AsRawResponses())
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (string item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
}

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<string> singlePage = response.ReadPage(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (string item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

FetchStaticIpsAsync(LocationName, String, Nullable<Int32>, CallSettings)

public virtual PagedAsyncEnumerable<FetchStaticIpsResponse, string> FetchStaticIpsAsync(LocationName name, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
LocationName name = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]");
// Make the request
PagedAsyncEnumerable<FetchStaticIpsResponse, string> response = datastreamClient.FetchStaticIpsAsync(name);

// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((string item) =>
{
    // Do something with each item
    Console.WriteLine(item);
});

// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((FetchStaticIpsResponse page) =>
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (string item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
});

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<string> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (string item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

FetchStaticIpsAsync(FetchStaticIpsRequest, CallSettings)

public virtual PagedAsyncEnumerable<FetchStaticIpsResponse, string> FetchStaticIpsAsync(FetchStaticIpsRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
FetchStaticIpsRequest request = new FetchStaticIpsRequest
{
    LocationName = LocationName.FromProjectLocation("[PROJECT]", "[LOCATION]"),
};
// Make the request
PagedAsyncEnumerable<FetchStaticIpsResponse, string> response = datastreamClient.FetchStaticIpsAsync(request);

// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((string item) =>
{
    // Do something with each item
    Console.WriteLine(item);
});

// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((FetchStaticIpsResponse page) =>
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (string item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
});

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<string> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (string item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

FetchStaticIpsAsync(String, String, Nullable<Int32>, CallSettings)

public virtual PagedAsyncEnumerable<FetchStaticIpsResponse, string> FetchStaticIpsAsync(string name, string pageToken = null, int? pageSize = null, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]";
// Make the request
PagedAsyncEnumerable<FetchStaticIpsResponse, string> response = datastreamClient.FetchStaticIpsAsync(name);

// Iterate over all response items, lazily performing RPCs as required
await response.ForEachAsync((string item) =>
{
    // Do something with each item
    Console.WriteLine(item);
});

// Or iterate over pages (of server-defined size), performing one RPC per page
await response.AsRawResponses().ForEachAsync((FetchStaticIpsResponse page) =>
{
    // Do something with each page of items
    Console.WriteLine("A page of results:");
    foreach (string item in page)
    {
        // Do something with each item
        Console.WriteLine(item);
    }
});

// Or retrieve a single page of known size (unless it's the final page), performing as many RPCs as required
int pageSize = 10;
Page<string> singlePage = await response.ReadPageAsync(pageSize);
// Do something with the page of items
Console.WriteLine($"A page of {pageSize} results (unless it's the final page):");
foreach (string item in singlePage)
{
    // Do something with each item
    Console.WriteLine(item);
}
// Store the pageToken, for when the next page is required.
string nextPageToken = singlePage.NextPageToken;

GetConnectionProfile(ConnectionProfileName, CallSettings)

public virtual ConnectionProfile GetConnectionProfile(ConnectionProfileName name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
ConnectionProfileName name = ConnectionProfileName.FromProjectLocationConnectionProfile("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]");
// Make the request
ConnectionProfile response = datastreamClient.GetConnectionProfile(name);

GetConnectionProfile(GetConnectionProfileRequest, CallSettings)

public virtual ConnectionProfile GetConnectionProfile(GetConnectionProfileRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
GetConnectionProfileRequest request = new GetConnectionProfileRequest
{
    ConnectionProfileName = ConnectionProfileName.FromProjectLocationConnectionProfile("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]"),
};
// Make the request
ConnectionProfile response = datastreamClient.GetConnectionProfile(request);

GetConnectionProfile(String, CallSettings)

public virtual ConnectionProfile GetConnectionProfile(string name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/connectionProfiles/[CONNECTION_PROFILE]";
// Make the request
ConnectionProfile response = datastreamClient.GetConnectionProfile(name);

GetConnectionProfileAsync(ConnectionProfileName, CallSettings)

public virtual Task<ConnectionProfile> GetConnectionProfileAsync(ConnectionProfileName name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
ConnectionProfileName name = ConnectionProfileName.FromProjectLocationConnectionProfile("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]");
// Make the request
ConnectionProfile response = await datastreamClient.GetConnectionProfileAsync(name);

GetConnectionProfileAsync(ConnectionProfileName, CancellationToken)

public virtual Task<ConnectionProfile> GetConnectionProfileAsync(ConnectionProfileName name, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
ConnectionProfileName name = ConnectionProfileName.FromProjectLocationConnectionProfile("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]");
// Make the request
ConnectionProfile response = await datastreamClient.GetConnectionProfileAsync(name);

GetConnectionProfileAsync(GetConnectionProfileRequest, CallSettings)

public virtual Task<ConnectionProfile> GetConnectionProfileAsync(GetConnectionProfileRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
GetConnectionProfileRequest request = new GetConnectionProfileRequest
{
    ConnectionProfileName = ConnectionProfileName.FromProjectLocationConnectionProfile("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]"),
};
// Make the request
ConnectionProfile response = await datastreamClient.GetConnectionProfileAsync(request);

GetConnectionProfileAsync(GetConnectionProfileRequest, CancellationToken)

public virtual Task<ConnectionProfile> GetConnectionProfileAsync(GetConnectionProfileRequest request, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
GetConnectionProfileRequest request = new GetConnectionProfileRequest
{
    ConnectionProfileName = ConnectionProfileName.FromProjectLocationConnectionProfile("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]"),
};
// Make the request
ConnectionProfile response = await datastreamClient.GetConnectionProfileAsync(request);

GetConnectionProfileAsync(String, CallSettings)

public virtual Task<ConnectionProfile> GetConnectionProfileAsync(string name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/connectionProfiles/[CONNECTION_PROFILE]";
// Make the request
ConnectionProfile response = await datastreamClient.GetConnectionProfileAsync(name);

GetConnectionProfileAsync(String, CancellationToken)

public virtual Task<ConnectionProfile> GetConnectionProfileAsync(string name, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/connectionProfiles/[CONNECTION_PROFILE]";
// Make the request
ConnectionProfile response = await datastreamClient.GetConnectionProfileAsync(name);

GetPrivateConnection(GetPrivateConnectionRequest, CallSettings)

public virtual PrivateConnection GetPrivateConnection(GetPrivateConnectionRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
GetPrivateConnectionRequest request = new GetPrivateConnectionRequest
{
    PrivateConnectionName = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]"),
};
// Make the request
PrivateConnection response = datastreamClient.GetPrivateConnection(request);

GetPrivateConnection(PrivateConnectionName, CallSettings)

public virtual PrivateConnection GetPrivateConnection(PrivateConnectionName name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
PrivateConnectionName name = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
// Make the request
PrivateConnection response = datastreamClient.GetPrivateConnection(name);

GetPrivateConnection(String, CallSettings)

public virtual PrivateConnection GetPrivateConnection(string name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]";
// Make the request
PrivateConnection response = datastreamClient.GetPrivateConnection(name);

GetPrivateConnectionAsync(GetPrivateConnectionRequest, CallSettings)

public virtual Task<PrivateConnection> GetPrivateConnectionAsync(GetPrivateConnectionRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
GetPrivateConnectionRequest request = new GetPrivateConnectionRequest
{
    PrivateConnectionName = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]"),
};
// Make the request
PrivateConnection response = await datastreamClient.GetPrivateConnectionAsync(request);

GetPrivateConnectionAsync(GetPrivateConnectionRequest, CancellationToken)

public virtual Task<PrivateConnection> GetPrivateConnectionAsync(GetPrivateConnectionRequest request, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
GetPrivateConnectionRequest request = new GetPrivateConnectionRequest
{
    PrivateConnectionName = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]"),
};
// Make the request
PrivateConnection response = await datastreamClient.GetPrivateConnectionAsync(request);

GetPrivateConnectionAsync(PrivateConnectionName, CallSettings)

public virtual Task<PrivateConnection> GetPrivateConnectionAsync(PrivateConnectionName name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
PrivateConnectionName name = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
// Make the request
PrivateConnection response = await datastreamClient.GetPrivateConnectionAsync(name);

GetPrivateConnectionAsync(PrivateConnectionName, CancellationToken)

public virtual Task<PrivateConnection> GetPrivateConnectionAsync(PrivateConnectionName name, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
PrivateConnectionName name = PrivateConnectionName.FromProjectLocationPrivateConnection("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
// Make the request
PrivateConnection response = await datastreamClient.GetPrivateConnectionAsync(name);

GetPrivateConnectionAsync(String, CallSettings)

public virtual Task<PrivateConnection> GetPrivateConnectionAsync(string name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]";
// Make the request
PrivateConnection response = await datastreamClient.GetPrivateConnectionAsync(name);

GetPrivateConnectionAsync(String, CancellationToken)

public virtual Task<PrivateConnection> GetPrivateConnectionAsync(string name, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]";
// Make the request
PrivateConnection response = await datastreamClient.GetPrivateConnectionAsync(name);

GetRoute(GetRouteRequest, CallSettings)

public virtual Route GetRoute(GetRouteRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
GetRouteRequest request = new GetRouteRequest
{
    RouteName = RouteName.FromProjectLocationPrivateConnectionRoute("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]"),
};
// Make the request
Route response = datastreamClient.GetRoute(request);

GetRoute(RouteName, CallSettings)

public virtual Route GetRoute(RouteName name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
RouteName name = RouteName.FromProjectLocationPrivateConnectionRoute("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]");
// Make the request
Route response = datastreamClient.GetRoute(name);

GetRoute(String, CallSettings)

public virtual Route GetRoute(string name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]/routes/[ROUTE]";
// Make the request
Route response = datastreamClient.GetRoute(name);

GetRouteAsync(GetRouteRequest, CallSettings)

public virtual Task<Route> GetRouteAsync(GetRouteRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
GetRouteRequest request = new GetRouteRequest
{
    RouteName = RouteName.FromProjectLocationPrivateConnectionRoute("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]"),
};
// Make the request
Route response = await datastreamClient.GetRouteAsync(request);

GetRouteAsync(GetRouteRequest, CancellationToken)

public virtual Task<Route> GetRouteAsync(GetRouteRequest request, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
GetRouteRequest request = new GetRouteRequest
{
    RouteName = RouteName.FromProjectLocationPrivateConnectionRoute("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]"),
};
// Make the request
Route response = await datastreamClient.GetRouteAsync(request);

GetRouteAsync(RouteName, CallSettings)

public virtual Task<Route> GetRouteAsync(RouteName name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
RouteName name = RouteName.FromProjectLocationPrivateConnectionRoute("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]");
// Make the request
Route response = await datastreamClient.GetRouteAsync(name);

GetRouteAsync(RouteName, CancellationToken)

public virtual Task<Route> GetRouteAsync(RouteName name, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
RouteName name = RouteName.FromProjectLocationPrivateConnectionRoute("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]");
// Make the request
Route response = await datastreamClient.GetRouteAsync(name);

GetRouteAsync(String, CallSettings)

public virtual Task<Route> GetRouteAsync(string name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]/routes/[ROUTE]";
// Make the request
Route response = await datastreamClient.GetRouteAsync(name);

GetRouteAsync(String, CancellationToken)

public virtual Task<Route> GetRouteAsync(string name, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/privateConnections/[PRIVATE_CONNECTION]/routes/[ROUTE]";
// Make the request
Route response = await datastreamClient.GetRouteAsync(name);

GetStream(GetStreamRequest, CallSettings)

public virtual Stream GetStream(GetStreamRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
GetStreamRequest request = new GetStreamRequest
{
    StreamName = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]"),
};
// Make the request
Stream response = datastreamClient.GetStream(request);

GetStream(StreamName, CallSettings)

public virtual Stream GetStream(StreamName name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
StreamName name = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]");
// Make the request
Stream response = datastreamClient.GetStream(name);

GetStream(String, CallSettings)

public virtual Stream GetStream(string name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/streams/[STREAM]";
// Make the request
Stream response = datastreamClient.GetStream(name);

GetStreamAsync(GetStreamRequest, CallSettings)

public virtual Task<Stream> GetStreamAsync(GetStreamRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
GetStreamRequest request = new GetStreamRequest
{
    StreamName = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]"),
};
// Make the request
Stream response = await datastreamClient.GetStreamAsync(request);

GetStreamAsync(GetStreamRequest, CancellationToken)

public virtual Task<Stream> GetStreamAsync(GetStreamRequest request, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
GetStreamRequest request = new GetStreamRequest
{
    StreamName = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]"),
};
// Make the request
Stream response = await datastreamClient.GetStreamAsync(request);

GetStreamAsync(StreamName, CallSettings)

public virtual Task<Stream> GetStreamAsync(StreamName name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
StreamName name = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]");
// Make the request
Stream response = await datastreamClient.GetStreamAsync(name);

GetStreamAsync(StreamName, CancellationToken)

public virtual Task<Stream> GetStreamAsync(StreamName name, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
StreamName name = StreamName.FromProjectLocationStream("[PROJECT]", "[LOCATION]", "[STREAM]");
// Make the request
Stream response = await datastreamClient.GetStreamAsync(name);

GetStreamAsync(String, CallSettings)

public virtual Task<Stream> GetStreamAsync(string name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/streams/[STREAM]";
// Make the request
Stream response = await datastreamClient.GetStreamAsync(name);

GetStreamAsync(String, CancellationToken)

public virtual Task<Stream> GetStreamAsync(string name, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/streams/[STREAM]";
// Make the request
Stream response = await datastreamClient.GetStreamAsync(name);

GetStreamObject(GetStreamObjectRequest, CallSettings)

public virtual StreamObject GetStreamObject(GetStreamObjectRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
GetStreamObjectRequest request = new GetStreamObjectRequest
{
    StreamObjectName = StreamObjectName.FromProjectLocationStreamObject("[PROJECT]", "[LOCATION]", "[STREAM]", "[OBJECT]"),
};
// Make the request
StreamObject response = datastreamClient.GetStreamObject(request);

GetStreamObject(StreamObjectName, CallSettings)

public virtual StreamObject GetStreamObject(StreamObjectName name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
StreamObjectName name = StreamObjectName.FromProjectLocationStreamObject("[PROJECT]", "[LOCATION]", "[STREAM]", "[OBJECT]");
// Make the request
StreamObject response = datastreamClient.GetStreamObject(name);

GetStreamObject(String, CallSettings)

public virtual StreamObject GetStreamObject(string name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = DatastreamClient.Create();
// Initialize request argument(s)
string name = "projects/[PROJECT]/locations/[LOCATION]/streams/[STREAM]/objects/[OBJECT]";
// Make the request
StreamObject response = datastreamClient.GetStreamObject(name);

GetStreamObjectAsync(GetStreamObjectRequest, CallSettings)

public virtual Task<StreamObject> GetStreamObjectAsync(GetStreamObjectRequest request, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
GetStreamObjectRequest request = new GetStreamObjectRequest
{
    StreamObjectName = StreamObjectName.FromProjectLocationStreamObject("[PROJECT]", "[LOCATION]", "[STREAM]", "[OBJECT]"),
};
// Make the request
StreamObject response = await datastreamClient.GetStreamObjectAsync(request);

GetStreamObjectAsync(GetStreamObjectRequest, CancellationToken)

public virtual Task<StreamObject> GetStreamObjectAsync(GetStreamObjectRequest request, CancellationToken cancellationToken)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
GetStreamObjectRequest request = new GetStreamObjectRequest
{
    StreamObjectName = StreamObjectName.FromProjectLocationStreamObject("[PROJECT]", "[LOCATION]", "[STREAM]", "[OBJECT]"),
};
// Make the request
StreamObject response = await datastreamClient.GetStreamObjectAsync(request);

GetStreamObjectAsync(StreamObjectName, CallSettings)

public virtual Task<StreamObject> GetStreamObjectAsync(StreamObjectName name, CallSettings callSettings = null)

// Create client
DatastreamClient datastreamClient = await DatastreamClient.CreateAsync();
// Initialize request argument(s)
StreamObjectName name = StreamObjectName.FromProjectLocationStreamObject("[PROJECT]", "[LOCATION]", "[STREAM]", "[OBJECT]");
// Make the request
StreamObject response = await datastreamClient.GetStreamObjectAsync(name);

GetStreamObjectAsync(StreamObjectName, CancellationToken)

public virtual Task<StreamObject> GetStreamObjectAsync(StreamObjectName name, CancellationToken cancellationToken)