Golang grpc.ServerStream类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Golang中google/golang.org/grpc.ServerStream类的典型用法代码示例。如果您正苦于以下问题：Golang ServerStream类的具体用法？Golang ServerStream怎么用？Golang ServerStream使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

在下文中一共展示了ServerStream类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Golang代码示例。

示例1: _ReplicationTransport_Query_Handler

func _ReplicationTransport_Query_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(QueryRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(ReplicationTransportServer).Query(m, &replicationTransportQueryServer{stream})
}

开发者ID:rayram23，项目名称:crdt，代码行数:7，代码来源:transport.pb.go

示例2: _RouteGuide_ListFeatures_Handler

func _RouteGuide_ListFeatures_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(Rectangle)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(RouteGuideServer).ListFeatures(m, &routeGuideListFeaturesServer{stream})
}

开发者ID:CocoaWang，项目名称:grpc-go，代码行数:7，代码来源:route_guide.pb.go

示例3: _Doppler_Firehose_Handler

func _Doppler_Firehose_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(FirehoseRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(DopplerServer).Firehose(m, &dopplerFirehoseServer{stream})
}

开发者ID:kei-yamazaki，项目名称:loggregator，代码行数:7，代码来源:plumbing.pb.go

示例4: _TestService_StreamingOutputCall_Handler

func _TestService_StreamingOutputCall_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(StreamingOutputCallRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(TestServiceServer).StreamingOutputCall(m, &testServiceStreamingOutputCallServer{stream})
}

开发者ID:Clarifai，项目名称:kubernetes，代码行数:7，代码来源:test.pb.go

示例5: _ByteStream_Read_Handler

func _ByteStream_Read_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(ReadRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(ByteStreamServer).Read(m, &byteStreamReadServer{stream})
}

开发者ID:jfrazelle，项目名称:s3server，代码行数:7，代码来源:bytestream.pb.go

示例6: _ShardedGraphStore_Shard_Handler

func _ShardedGraphStore_Shard_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(ShardRequest)
	if err := stream.RecvProto(m); err != nil {
		return err
	}
	return srv.(ShardedGraphStoreServer).Shard(m, &shardedGraphStoreShardServer{stream})
}

开发者ID:gameduell，项目名称:kythe，代码行数:7，代码来源:storage.pb.go

示例7: _API_GetBlock_Handler

func _API_GetBlock_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(GetBlockRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(APIServer).GetBlock(m, &aPIGetBlockServer{stream})
}

开发者ID:tottok-ug，项目名称:pachyderm，代码行数:7，代码来源:drive.pb.go

示例8: _CompilationAnalyzer_Analyze_Handler

func _CompilationAnalyzer_Analyze_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(AnalysisRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(CompilationAnalyzerServer).Analyze(m, &compilationAnalyzerAnalyzeServer{stream})
}

开发者ID:baev，项目名称:kythe，代码行数:7，代码来源:analysis.pb.go

示例9: _FileDataService_Get_Handler

func _FileDataService_Get_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(FilesRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(FileDataServiceServer).Get(m, &fileDataServiceGetServer{stream})
}

开发者ID:baev，项目名称:kythe，代码行数:7，代码来源:analysis.pb.go

示例10: _ABitOfEverythingService_List_Handler

func _ABitOfEverythingService_List_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(EmptyMessage)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(ABitOfEverythingServiceServer).List(m, &aBitOfEverythingServiceListServer{stream})
}

开发者ID:ZubairNabi，项目名称:grpc-gateway，代码行数:7，代码来源:a_bit_of_everything.pb.go

示例11: _LongTests_RandomStrings_Handler

func _LongTests_RandomStrings_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(RandomStringsRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(LongTestsServer).RandomStrings(m, &longTestsRandomStringsServer{stream})
}

开发者ID:stepancheg，项目名称:grpc-rust，代码行数:7，代码来源:long_tests_pb.pb.go

示例12: _TestService_List_Handler

func _TestService_List_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(ListOptions)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(TestServiceServer).List(m, &testServiceListServer{stream})
}

开发者ID:limbo-services，项目名称:core，代码行数:7，代码来源:example.pb.go

示例13: _RPC_WatchMessage_Handler

func _RPC_WatchMessage_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(Send)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(RPCServer).WatchMessage(m, &rPCWatchMessageServer{stream})
}

开发者ID:vanishs，项目名称:gwsrpc，代码行数:7，代码来源:aaa.pb.go

示例14: _TestService_PingList_Handler

func _TestService_PingList_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(PingRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(TestServiceServer).PingList(m, &testServicePingListServer{stream})
}

开发者ID:mwitkow，项目名称:grpc-proxy，代码行数:7，代码来源:test.pb.go

示例15: _GraphStore_Read_Handler

func _GraphStore_Read_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(ReadRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(GraphStoreServer).Read(m, &graphStoreReadServer{stream})
}

开发者ID:herberteuler，项目名称:kythe，代码行数:7，代码来源:storage.pb.go

示例16: _ChatService_Read_Handler

func _ChatService_Read_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(Chat_Id)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(ChatServiceServer).Read(m, &chatServiceReadServer{stream})
}

开发者ID:pengswift，项目名称:chat，代码行数:7，代码来源:chat.pb.go

示例17: _GraphStore_Scan_Handler

func _GraphStore_Scan_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(ScanRequest)
	if err := stream.RecvProto(m); err != nil {
		return err
	}
	return srv.(GraphStoreServer).Scan(m, &graphStoreScanServer{stream})
}

开发者ID:gameduell，项目名称:kythe，代码行数:7，代码来源:storage.pb.go

示例18: _UpdateStream_StreamTables_Handler

func _UpdateStream_StreamTables_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(binlogdata.StreamTablesRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(UpdateStreamServer).StreamTables(m, &updateStreamStreamTablesServer{stream})
}

开发者ID:aaijazi，项目名称:vitess，代码行数:7，代码来源:binlogservice.pb.go

示例19: _Vitess_StreamExecuteKeyRanges_Handler

func _Vitess_StreamExecuteKeyRanges_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(vtgate.StreamExecuteKeyRangesRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(VitessServer).StreamExecuteKeyRanges(m, &vitessStreamExecuteKeyRangesServer{stream})
}

开发者ID:jmptrader，项目名称:vitess，代码行数:7，代码来源:vtgateservice.pb.go

示例20: _BigtableService_ReadRows_Handler

func _BigtableService_ReadRows_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(ReadRowsRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(BigtableServiceServer).ReadRows(m, &bigtableServiceReadRowsServer{stream})
}

开发者ID:cjmagee，项目名称:howsmyssl，代码行数:7，代码来源:bigtable_service.pb.go

注：本文中的google/golang.org/grpc.ServerStream类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。