From f21eb009863396ce603edf0d61287b52efbee404 Mon Sep 17 00:00:00 2001 From: Ethan Date: Wed, 15 May 2024 08:44:43 -0400 Subject: [PATCH] move to api's gostream (#210) --- Makefile | 1 - buf.yaml | 1 - lib/src/gen/proto/stream/v1/stream.pb.dart | 264 ------------------ .../gen/proto/stream/v1/stream.pbenum.dart | 11 - .../gen/proto/stream/v1/stream.pbgrpc.dart | 99 ------- .../gen/proto/stream/v1/stream.pbjson.dart | 78 ------ lib/src/media/stream/client.dart | 2 +- 7 files changed, 1 insertion(+), 455 deletions(-) delete mode 100644 lib/src/gen/proto/stream/v1/stream.pb.dart delete mode 100644 lib/src/gen/proto/stream/v1/stream.pbenum.dart delete mode 100644 lib/src/gen/proto/stream/v1/stream.pbgrpc.dart delete mode 100644 lib/src/gen/proto/stream/v1/stream.pbjson.dart diff --git a/Makefile b/Makefile index 4bf2e337dfe..1fb8170f63d 100644 --- a/Makefile +++ b/Makefile @@ -12,7 +12,6 @@ buf: buf.yaml buf.gen.yaml rm -rf lib/src/gen PATH=$(PATH_WITH_TOOLS) buf generate buf.build/viamrobotics/goutils PATH=$(PATH_WITH_TOOLS) buf generate buf.build/viamrobotics/api - PATH=$(PATH_WITH_TOOLS) buf generate buf.build/erdaniels/gostream PATH=$(PATH_WITH_TOOLS) buf generate buf.build/googleapis/googleapis PATH=$(PATH_WITH_TOOLS) buf generate buf.build/protocolbuffers/wellknowntypes --path google/protobuf/any.proto PATH=$(PATH_WITH_TOOLS) buf generate buf.build/protocolbuffers/wellknowntypes --path google/protobuf/duration.proto diff --git a/buf.yaml b/buf.yaml index c1fd0bd2d41..168981dd70c 100644 --- a/buf.yaml +++ b/buf.yaml @@ -8,4 +8,3 @@ lint: deps: - buf.build/viamrobotics/goutils - buf.build/viamrobotics/api - - buf.build/erdaniels/gostream diff --git a/lib/src/gen/proto/stream/v1/stream.pb.dart b/lib/src/gen/proto/stream/v1/stream.pb.dart deleted file mode 100644 index 55c72e45c32..00000000000 --- a/lib/src/gen/proto/stream/v1/stream.pb.dart +++ /dev/null @@ -1,264 +0,0 @@ -// -// Generated code. Do not modify. -// source: proto/stream/v1/stream.proto -// -// @dart = 2.12 - -// ignore_for_file: annotate_overrides, camel_case_types, comment_references -// ignore_for_file: constant_identifier_names, library_prefixes -// ignore_for_file: non_constant_identifier_names, prefer_final_fields -// ignore_for_file: unnecessary_import, unnecessary_this, unused_import - -import 'dart:core' as $core; - -import 'package:protobuf/protobuf.dart' as $pb; - -/// ListStreamsRequest requests all streams registered. -class ListStreamsRequest extends $pb.GeneratedMessage { - factory ListStreamsRequest() => create(); - ListStreamsRequest._() : super(); - factory ListStreamsRequest.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r); - factory ListStreamsRequest.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r); - - static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'ListStreamsRequest', package: const $pb.PackageName(_omitMessageNames ? '' : 'proto.stream.v1'), createEmptyInstance: create) - ..hasRequiredFields = false - ; - - @$core.Deprecated( - 'Using this can add significant overhead to your binary. ' - 'Use [GeneratedMessageGenericExtensions.deepCopy] instead. ' - 'Will be removed in next major version') - ListStreamsRequest clone() => ListStreamsRequest()..mergeFromMessage(this); - @$core.Deprecated( - 'Using this can add significant overhead to your binary. ' - 'Use [GeneratedMessageGenericExtensions.rebuild] instead. ' - 'Will be removed in next major version') - ListStreamsRequest copyWith(void Function(ListStreamsRequest) updates) => super.copyWith((message) => updates(message as ListStreamsRequest)) as ListStreamsRequest; - - $pb.BuilderInfo get info_ => _i; - - @$core.pragma('dart2js:noInline') - static ListStreamsRequest create() => ListStreamsRequest._(); - ListStreamsRequest createEmptyInstance() => create(); - static $pb.PbList createRepeated() => $pb.PbList(); - @$core.pragma('dart2js:noInline') - static ListStreamsRequest getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor(create); - static ListStreamsRequest? _defaultInstance; -} - -/// A ListStreamsResponse details streams registered. -class ListStreamsResponse extends $pb.GeneratedMessage { - factory ListStreamsResponse({ - $core.Iterable<$core.String>? names, - }) { - final $result = create(); - if (names != null) { - $result.names.addAll(names); - } - return $result; - } - ListStreamsResponse._() : super(); - factory ListStreamsResponse.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r); - factory ListStreamsResponse.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r); - - static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'ListStreamsResponse', package: const $pb.PackageName(_omitMessageNames ? '' : 'proto.stream.v1'), createEmptyInstance: create) - ..pPS(1, _omitFieldNames ? '' : 'names') - ..hasRequiredFields = false - ; - - @$core.Deprecated( - 'Using this can add significant overhead to your binary. ' - 'Use [GeneratedMessageGenericExtensions.deepCopy] instead. ' - 'Will be removed in next major version') - ListStreamsResponse clone() => ListStreamsResponse()..mergeFromMessage(this); - @$core.Deprecated( - 'Using this can add significant overhead to your binary. ' - 'Use [GeneratedMessageGenericExtensions.rebuild] instead. ' - 'Will be removed in next major version') - ListStreamsResponse copyWith(void Function(ListStreamsResponse) updates) => super.copyWith((message) => updates(message as ListStreamsResponse)) as ListStreamsResponse; - - $pb.BuilderInfo get info_ => _i; - - @$core.pragma('dart2js:noInline') - static ListStreamsResponse create() => ListStreamsResponse._(); - ListStreamsResponse createEmptyInstance() => create(); - static $pb.PbList createRepeated() => $pb.PbList(); - @$core.pragma('dart2js:noInline') - static ListStreamsResponse getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor(create); - static ListStreamsResponse? _defaultInstance; - - @$pb.TagNumber(1) - $core.List<$core.String> get names => $_getList(0); -} - -/// A AddStreamRequest requests the given stream be added to the connection. -class AddStreamRequest extends $pb.GeneratedMessage { - factory AddStreamRequest({ - $core.String? name, - }) { - final $result = create(); - if (name != null) { - $result.name = name; - } - return $result; - } - AddStreamRequest._() : super(); - factory AddStreamRequest.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r); - factory AddStreamRequest.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r); - - static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'AddStreamRequest', package: const $pb.PackageName(_omitMessageNames ? '' : 'proto.stream.v1'), createEmptyInstance: create) - ..aOS(1, _omitFieldNames ? '' : 'name') - ..hasRequiredFields = false - ; - - @$core.Deprecated( - 'Using this can add significant overhead to your binary. ' - 'Use [GeneratedMessageGenericExtensions.deepCopy] instead. ' - 'Will be removed in next major version') - AddStreamRequest clone() => AddStreamRequest()..mergeFromMessage(this); - @$core.Deprecated( - 'Using this can add significant overhead to your binary. ' - 'Use [GeneratedMessageGenericExtensions.rebuild] instead. ' - 'Will be removed in next major version') - AddStreamRequest copyWith(void Function(AddStreamRequest) updates) => super.copyWith((message) => updates(message as AddStreamRequest)) as AddStreamRequest; - - $pb.BuilderInfo get info_ => _i; - - @$core.pragma('dart2js:noInline') - static AddStreamRequest create() => AddStreamRequest._(); - AddStreamRequest createEmptyInstance() => create(); - static $pb.PbList createRepeated() => $pb.PbList(); - @$core.pragma('dart2js:noInline') - static AddStreamRequest getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor(create); - static AddStreamRequest? _defaultInstance; - - @$pb.TagNumber(1) - $core.String get name => $_getSZ(0); - @$pb.TagNumber(1) - set name($core.String v) { $_setString(0, v); } - @$pb.TagNumber(1) - $core.bool hasName() => $_has(0); - @$pb.TagNumber(1) - void clearName() => clearField(1); -} - -/// AddStreamResponse is returned after a successful AddStreamRequest. -class AddStreamResponse extends $pb.GeneratedMessage { - factory AddStreamResponse() => create(); - AddStreamResponse._() : super(); - factory AddStreamResponse.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r); - factory AddStreamResponse.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r); - - static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'AddStreamResponse', package: const $pb.PackageName(_omitMessageNames ? '' : 'proto.stream.v1'), createEmptyInstance: create) - ..hasRequiredFields = false - ; - - @$core.Deprecated( - 'Using this can add significant overhead to your binary. ' - 'Use [GeneratedMessageGenericExtensions.deepCopy] instead. ' - 'Will be removed in next major version') - AddStreamResponse clone() => AddStreamResponse()..mergeFromMessage(this); - @$core.Deprecated( - 'Using this can add significant overhead to your binary. ' - 'Use [GeneratedMessageGenericExtensions.rebuild] instead. ' - 'Will be removed in next major version') - AddStreamResponse copyWith(void Function(AddStreamResponse) updates) => super.copyWith((message) => updates(message as AddStreamResponse)) as AddStreamResponse; - - $pb.BuilderInfo get info_ => _i; - - @$core.pragma('dart2js:noInline') - static AddStreamResponse create() => AddStreamResponse._(); - AddStreamResponse createEmptyInstance() => create(); - static $pb.PbList createRepeated() => $pb.PbList(); - @$core.pragma('dart2js:noInline') - static AddStreamResponse getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor(create); - static AddStreamResponse? _defaultInstance; -} - -/// A RemoveStreamRequest requests the given stream be removed from the connection. -class RemoveStreamRequest extends $pb.GeneratedMessage { - factory RemoveStreamRequest({ - $core.String? name, - }) { - final $result = create(); - if (name != null) { - $result.name = name; - } - return $result; - } - RemoveStreamRequest._() : super(); - factory RemoveStreamRequest.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r); - factory RemoveStreamRequest.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r); - - static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'RemoveStreamRequest', package: const $pb.PackageName(_omitMessageNames ? '' : 'proto.stream.v1'), createEmptyInstance: create) - ..aOS(1, _omitFieldNames ? '' : 'name') - ..hasRequiredFields = false - ; - - @$core.Deprecated( - 'Using this can add significant overhead to your binary. ' - 'Use [GeneratedMessageGenericExtensions.deepCopy] instead. ' - 'Will be removed in next major version') - RemoveStreamRequest clone() => RemoveStreamRequest()..mergeFromMessage(this); - @$core.Deprecated( - 'Using this can add significant overhead to your binary. ' - 'Use [GeneratedMessageGenericExtensions.rebuild] instead. ' - 'Will be removed in next major version') - RemoveStreamRequest copyWith(void Function(RemoveStreamRequest) updates) => super.copyWith((message) => updates(message as RemoveStreamRequest)) as RemoveStreamRequest; - - $pb.BuilderInfo get info_ => _i; - - @$core.pragma('dart2js:noInline') - static RemoveStreamRequest create() => RemoveStreamRequest._(); - RemoveStreamRequest createEmptyInstance() => create(); - static $pb.PbList createRepeated() => $pb.PbList(); - @$core.pragma('dart2js:noInline') - static RemoveStreamRequest getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor(create); - static RemoveStreamRequest? _defaultInstance; - - @$pb.TagNumber(1) - $core.String get name => $_getSZ(0); - @$pb.TagNumber(1) - set name($core.String v) { $_setString(0, v); } - @$pb.TagNumber(1) - $core.bool hasName() => $_has(0); - @$pb.TagNumber(1) - void clearName() => clearField(1); -} - -/// RemoveStreamResponse is returned after a successful RemoveStreamRequest. -class RemoveStreamResponse extends $pb.GeneratedMessage { - factory RemoveStreamResponse() => create(); - RemoveStreamResponse._() : super(); - factory RemoveStreamResponse.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r); - factory RemoveStreamResponse.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r); - - static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'RemoveStreamResponse', package: const $pb.PackageName(_omitMessageNames ? '' : 'proto.stream.v1'), createEmptyInstance: create) - ..hasRequiredFields = false - ; - - @$core.Deprecated( - 'Using this can add significant overhead to your binary. ' - 'Use [GeneratedMessageGenericExtensions.deepCopy] instead. ' - 'Will be removed in next major version') - RemoveStreamResponse clone() => RemoveStreamResponse()..mergeFromMessage(this); - @$core.Deprecated( - 'Using this can add significant overhead to your binary. ' - 'Use [GeneratedMessageGenericExtensions.rebuild] instead. ' - 'Will be removed in next major version') - RemoveStreamResponse copyWith(void Function(RemoveStreamResponse) updates) => super.copyWith((message) => updates(message as RemoveStreamResponse)) as RemoveStreamResponse; - - $pb.BuilderInfo get info_ => _i; - - @$core.pragma('dart2js:noInline') - static RemoveStreamResponse create() => RemoveStreamResponse._(); - RemoveStreamResponse createEmptyInstance() => create(); - static $pb.PbList createRepeated() => $pb.PbList(); - @$core.pragma('dart2js:noInline') - static RemoveStreamResponse getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor(create); - static RemoveStreamResponse? _defaultInstance; -} - - -const _omitFieldNames = $core.bool.fromEnvironment('protobuf.omit_field_names'); -const _omitMessageNames = $core.bool.fromEnvironment('protobuf.omit_message_names'); diff --git a/lib/src/gen/proto/stream/v1/stream.pbenum.dart b/lib/src/gen/proto/stream/v1/stream.pbenum.dart deleted file mode 100644 index 71c9b6fdb89..00000000000 --- a/lib/src/gen/proto/stream/v1/stream.pbenum.dart +++ /dev/null @@ -1,11 +0,0 @@ -// -// Generated code. Do not modify. -// source: proto/stream/v1/stream.proto -// -// @dart = 2.12 - -// ignore_for_file: annotate_overrides, camel_case_types, comment_references -// ignore_for_file: constant_identifier_names, library_prefixes -// ignore_for_file: non_constant_identifier_names, prefer_final_fields -// ignore_for_file: unnecessary_import, unnecessary_this, unused_import - diff --git a/lib/src/gen/proto/stream/v1/stream.pbgrpc.dart b/lib/src/gen/proto/stream/v1/stream.pbgrpc.dart deleted file mode 100644 index 54ebf0490f6..00000000000 --- a/lib/src/gen/proto/stream/v1/stream.pbgrpc.dart +++ /dev/null @@ -1,99 +0,0 @@ -// -// Generated code. Do not modify. -// source: proto/stream/v1/stream.proto -// -// @dart = 2.12 - -// ignore_for_file: annotate_overrides, camel_case_types, comment_references -// ignore_for_file: constant_identifier_names, library_prefixes -// ignore_for_file: non_constant_identifier_names, prefer_final_fields -// ignore_for_file: unnecessary_import, unnecessary_this, unused_import - -import 'dart:async' as $async; -import 'dart:core' as $core; - -import 'package:grpc/service_api.dart' as $grpc; -import 'package:protobuf/protobuf.dart' as $pb; - -import 'stream.pb.dart' as $0; - -export 'stream.pb.dart'; - -@$pb.GrpcServiceName('proto.stream.v1.StreamService') -class StreamServiceClient extends $grpc.Client { - static final _$listStreams = $grpc.ClientMethod<$0.ListStreamsRequest, $0.ListStreamsResponse>( - '/proto.stream.v1.StreamService/ListStreams', - ($0.ListStreamsRequest value) => value.writeToBuffer(), - ($core.List<$core.int> value) => $0.ListStreamsResponse.fromBuffer(value)); - static final _$addStream = $grpc.ClientMethod<$0.AddStreamRequest, $0.AddStreamResponse>( - '/proto.stream.v1.StreamService/AddStream', - ($0.AddStreamRequest value) => value.writeToBuffer(), - ($core.List<$core.int> value) => $0.AddStreamResponse.fromBuffer(value)); - static final _$removeStream = $grpc.ClientMethod<$0.RemoveStreamRequest, $0.RemoveStreamResponse>( - '/proto.stream.v1.StreamService/RemoveStream', - ($0.RemoveStreamRequest value) => value.writeToBuffer(), - ($core.List<$core.int> value) => $0.RemoveStreamResponse.fromBuffer(value)); - - StreamServiceClient($grpc.ClientChannel channel, - {$grpc.CallOptions? options, - $core.Iterable<$grpc.ClientInterceptor>? interceptors}) - : super(channel, options: options, - interceptors: interceptors); - - $grpc.ResponseFuture<$0.ListStreamsResponse> listStreams($0.ListStreamsRequest request, {$grpc.CallOptions? options}) { - return $createUnaryCall(_$listStreams, request, options: options); - } - - $grpc.ResponseFuture<$0.AddStreamResponse> addStream($0.AddStreamRequest request, {$grpc.CallOptions? options}) { - return $createUnaryCall(_$addStream, request, options: options); - } - - $grpc.ResponseFuture<$0.RemoveStreamResponse> removeStream($0.RemoveStreamRequest request, {$grpc.CallOptions? options}) { - return $createUnaryCall(_$removeStream, request, options: options); - } -} - -@$pb.GrpcServiceName('proto.stream.v1.StreamService') -abstract class StreamServiceBase extends $grpc.Service { - $core.String get $name => 'proto.stream.v1.StreamService'; - - StreamServiceBase() { - $addMethod($grpc.ServiceMethod<$0.ListStreamsRequest, $0.ListStreamsResponse>( - 'ListStreams', - listStreams_Pre, - false, - false, - ($core.List<$core.int> value) => $0.ListStreamsRequest.fromBuffer(value), - ($0.ListStreamsResponse value) => value.writeToBuffer())); - $addMethod($grpc.ServiceMethod<$0.AddStreamRequest, $0.AddStreamResponse>( - 'AddStream', - addStream_Pre, - false, - false, - ($core.List<$core.int> value) => $0.AddStreamRequest.fromBuffer(value), - ($0.AddStreamResponse value) => value.writeToBuffer())); - $addMethod($grpc.ServiceMethod<$0.RemoveStreamRequest, $0.RemoveStreamResponse>( - 'RemoveStream', - removeStream_Pre, - false, - false, - ($core.List<$core.int> value) => $0.RemoveStreamRequest.fromBuffer(value), - ($0.RemoveStreamResponse value) => value.writeToBuffer())); - } - - $async.Future<$0.ListStreamsResponse> listStreams_Pre($grpc.ServiceCall call, $async.Future<$0.ListStreamsRequest> request) async { - return listStreams(call, await request); - } - - $async.Future<$0.AddStreamResponse> addStream_Pre($grpc.ServiceCall call, $async.Future<$0.AddStreamRequest> request) async { - return addStream(call, await request); - } - - $async.Future<$0.RemoveStreamResponse> removeStream_Pre($grpc.ServiceCall call, $async.Future<$0.RemoveStreamRequest> request) async { - return removeStream(call, await request); - } - - $async.Future<$0.ListStreamsResponse> listStreams($grpc.ServiceCall call, $0.ListStreamsRequest request); - $async.Future<$0.AddStreamResponse> addStream($grpc.ServiceCall call, $0.AddStreamRequest request); - $async.Future<$0.RemoveStreamResponse> removeStream($grpc.ServiceCall call, $0.RemoveStreamRequest request); -} diff --git a/lib/src/gen/proto/stream/v1/stream.pbjson.dart b/lib/src/gen/proto/stream/v1/stream.pbjson.dart deleted file mode 100644 index 56874f65f24..00000000000 --- a/lib/src/gen/proto/stream/v1/stream.pbjson.dart +++ /dev/null @@ -1,78 +0,0 @@ -// -// Generated code. Do not modify. -// source: proto/stream/v1/stream.proto -// -// @dart = 2.12 - -// ignore_for_file: annotate_overrides, camel_case_types, comment_references -// ignore_for_file: constant_identifier_names, library_prefixes -// ignore_for_file: non_constant_identifier_names, prefer_final_fields -// ignore_for_file: unnecessary_import, unnecessary_this, unused_import - -import 'dart:convert' as $convert; -import 'dart:core' as $core; -import 'dart:typed_data' as $typed_data; - -@$core.Deprecated('Use listStreamsRequestDescriptor instead') -const ListStreamsRequest$json = { - '1': 'ListStreamsRequest', -}; - -/// Descriptor for `ListStreamsRequest`. Decode as a `google.protobuf.DescriptorProto`. -final $typed_data.Uint8List listStreamsRequestDescriptor = $convert.base64Decode( - 'ChJMaXN0U3RyZWFtc1JlcXVlc3Q='); - -@$core.Deprecated('Use listStreamsResponseDescriptor instead') -const ListStreamsResponse$json = { - '1': 'ListStreamsResponse', - '2': [ - {'1': 'names', '3': 1, '4': 3, '5': 9, '10': 'names'}, - ], -}; - -/// Descriptor for `ListStreamsResponse`. Decode as a `google.protobuf.DescriptorProto`. -final $typed_data.Uint8List listStreamsResponseDescriptor = $convert.base64Decode( - 'ChNMaXN0U3RyZWFtc1Jlc3BvbnNlEhQKBW5hbWVzGAEgAygJUgVuYW1lcw=='); - -@$core.Deprecated('Use addStreamRequestDescriptor instead') -const AddStreamRequest$json = { - '1': 'AddStreamRequest', - '2': [ - {'1': 'name', '3': 1, '4': 1, '5': 9, '10': 'name'}, - ], -}; - -/// Descriptor for `AddStreamRequest`. Decode as a `google.protobuf.DescriptorProto`. -final $typed_data.Uint8List addStreamRequestDescriptor = $convert.base64Decode( - 'ChBBZGRTdHJlYW1SZXF1ZXN0EhIKBG5hbWUYASABKAlSBG5hbWU='); - -@$core.Deprecated('Use addStreamResponseDescriptor instead') -const AddStreamResponse$json = { - '1': 'AddStreamResponse', -}; - -/// Descriptor for `AddStreamResponse`. Decode as a `google.protobuf.DescriptorProto`. -final $typed_data.Uint8List addStreamResponseDescriptor = $convert.base64Decode( - 'ChFBZGRTdHJlYW1SZXNwb25zZQ=='); - -@$core.Deprecated('Use removeStreamRequestDescriptor instead') -const RemoveStreamRequest$json = { - '1': 'RemoveStreamRequest', - '2': [ - {'1': 'name', '3': 1, '4': 1, '5': 9, '10': 'name'}, - ], -}; - -/// Descriptor for `RemoveStreamRequest`. Decode as a `google.protobuf.DescriptorProto`. -final $typed_data.Uint8List removeStreamRequestDescriptor = $convert.base64Decode( - 'ChNSZW1vdmVTdHJlYW1SZXF1ZXN0EhIKBG5hbWUYASABKAlSBG5hbWU='); - -@$core.Deprecated('Use removeStreamResponseDescriptor instead') -const RemoveStreamResponse$json = { - '1': 'RemoveStreamResponse', -}; - -/// Descriptor for `RemoveStreamResponse`. Decode as a `google.protobuf.DescriptorProto`. -final $typed_data.Uint8List removeStreamResponseDescriptor = $convert.base64Decode( - 'ChRSZW1vdmVTdHJlYW1SZXNwb25zZQ=='); - diff --git a/lib/src/media/stream/client.dart b/lib/src/media/stream/client.dart index ef77dcb4631..31eafb3b3c2 100644 --- a/lib/src/media/stream/client.dart +++ b/lib/src/media/stream/client.dart @@ -3,7 +3,7 @@ import 'dart:async'; import 'package:flutter_webrtc/flutter_webrtc.dart'; import 'package:logger/logger.dart'; -import '../../gen/proto/stream/v1/stream.pbgrpc.dart'; +import '../../gen/stream/v1/stream.pbgrpc.dart'; import '../../rpc/web_rtc/web_rtc_client.dart'; Logger _logger = Logger();