<gh_stars>1000+
# Copyright (c) Microsoft Corporation.
# Licensed under the MIT license.

from .stream import Stream
from .lv_types import StreamItem
import uuid

class ArrayStream(Stream):
    def __init__(self, array, stream_name:str=None, console_debug:bool=False):
        super(ArrayStream, self).__init__(stream_name=stream_name, console_debug=console_debug)

        self.stream_name = stream_name
        self.array = array

    def load(self, from_stream:'Stream'=None):
        if self.array is not None:
            self.write(self.array)
        super(ArrayStream, self).load()

# Copyright (c) Microsoft Corporation.
# Licensed under the MIT license.

from .stream import Stream
from .lv_types import StreamItem
import uuid

class ArrayStream(Stream):
    def __init__(self, array, stream_name:str=None, console_debug:bool=False):
        super(ArrayStream, self).__init__(stream_name=stream_name, console_debug=console_debug)

        self.stream_name = stream_name
        self.array = array

    def load(self, from_stream:'Stream'=None):
        if self.array is not None:
            self.write(self.array)
        super(ArrayStream, self).load()
# Copyright (c) Microsoft Corporation. # Licensed under the MIT license.