Merge "GD-SL4A: Add repeated connection test for background connections"

#   limitations under the License.

import time

from abc import ABC, abstractmethod

import logging

class Closable(ABC):

        return self

    def __exit__(self, type, value, traceback):

        try:

            self.close()

        except Exception:

            logging.warning("Failed to close or already closed")

        return traceback is None

    def __del__(self):

        try:

            self.close()

        except Exception:

            logging.warning("Failed to close or already closed")

    @abstractmethod

    def close(self):

        safeClose(self.connection_event_stream)

        safeClose(self.acl_stream)

    def wait_for_disconnection_complete(self):

    def disconnect(self):

        self.le_acl_manager.Disconnect(le_acl_manager_facade.LeHandleMsg(handle=self.handle))

    def wait_for_disconnection_complete(self, timeout=timedelta(seconds=30)):

        disconnection_complete = HciCaptures.DisconnectionCompleteCapture()

        assertThat(self.connection_event_stream).emits(disconnection_complete)

        assertThat(self.connection_event_stream).emits(disconnection_complete, timeout=timeout)

        self.disconnect_reason = disconnection_complete.get().GetReason()

    def send(self, data):