Skip to content

Commit 92a6380

Browse files
authored
Move bidi to api-core (#6211)
1 parent 3bf4b78 commit 92a6380

File tree

4 files changed

+3
-3
lines changed

4 files changed

+3
-3
lines changed

pubsub/tests/unit/pubsub_v1/subscriber/test_bidi.py renamed to api_core/tests/unit/test_bidi.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@
2121
from six.moves import queue
2222

2323
from google.api_core import exceptions
24-
from google.cloud.pubsub_v1.subscriber._protocol import bidi
24+
from google.api_core import bidi
2525

2626

2727
class Test_RequestQueueGenerator(object):

pubsub/google/cloud/pubsub_v1/subscriber/_protocol/streaming_pull_manager.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -22,9 +22,9 @@
2222
import grpc
2323
import six
2424

25+
from google.api_core import bidi
2526
from google.api_core import exceptions
2627
from google.cloud.pubsub_v1 import types
27-
from google.cloud.pubsub_v1.subscriber._protocol import bidi
2828
from google.cloud.pubsub_v1.subscriber._protocol import dispatcher
2929
from google.cloud.pubsub_v1.subscriber._protocol import heartbeater
3030
from google.cloud.pubsub_v1.subscriber._protocol import histogram

pubsub/tests/unit/pubsub_v1/subscriber/test_streaming_pull_manager.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -17,13 +17,13 @@
1717
import mock
1818
import pytest
1919

20+
from google.api_core import bidi
2021
from google.api_core import exceptions
2122
from google.cloud.pubsub_v1 import types
2223
from google.cloud.pubsub_v1.gapic import subscriber_client_config
2324
from google.cloud.pubsub_v1.subscriber import client
2425
from google.cloud.pubsub_v1.subscriber import message
2526
from google.cloud.pubsub_v1.subscriber import scheduler
26-
from google.cloud.pubsub_v1.subscriber._protocol import bidi
2727
from google.cloud.pubsub_v1.subscriber._protocol import dispatcher
2828
from google.cloud.pubsub_v1.subscriber._protocol import heartbeater
2929
from google.cloud.pubsub_v1.subscriber._protocol import leaser

0 commit comments

Comments
 (0)