missing keyword args for travis

This commit is contained in:
Jack 2016-06-04 15:03:16 -04:00
parent 3f929aee3c
commit febc66fb02
2 changed files with 9 additions and 6 deletions

View file

@ -15,7 +15,8 @@ from twisted.internet import defer, task
class LBRYStdinUploader(): class LBRYStdinUploader():
"""This class reads from standard in, creates a stream, and makes it available on the network.""" """This class reads from standard in, creates a stream, and makes it available on the network."""
def __init__(self, peer_port, dht_node_port, known_dht_nodes): def __init__(self, peer_port, dht_node_port, known_dht_nodes,
stream_info_manager_class=DBLiveStreamMetadataManager, blob_manager_class=TempBlobManager):
""" """
@param peer_port: the network port on which to listen for peers @param peer_port: the network port on which to listen for peers
@ -25,8 +26,8 @@ class LBRYStdinUploader():
""" """
self.peer_port = peer_port self.peer_port = peer_port
self.lbry_server_port = None self.lbry_server_port = None
self.session = LBRYSession(blob_manager_class=TempBlobManager, self.session = LBRYSession(blob_manager_class=blob_manager_class,
stream_info_manager_class=DBLiveStreamMetadataManager, stream_info_manager_class=stream_info_manager_class,
dht_node_class=Node, dht_node_port=dht_node_port, dht_node_class=Node, dht_node_port=dht_node_port,
known_dht_nodes=known_dht_nodes, peer_port=self.peer_port, known_dht_nodes=known_dht_nodes, peer_port=self.peer_port,
use_upnp=False) use_upnp=False)

View file

@ -15,15 +15,17 @@ from twisted.internet import task
class LBRYStdoutDownloader(): class LBRYStdoutDownloader():
"""This class downloads a live stream from the network and outputs it to standard out.""" """This class downloads a live stream from the network and outputs it to standard out."""
def __init__(self, dht_node_port, known_dht_nodes): def __init__(self, dht_node_port, known_dht_nodes,
stream_info_manager_class=DBLiveStreamMetadataManager, blob_manager_class=TempBlobManager):
""" """
@param dht_node_port: the network port on which to listen for DHT node requests @param dht_node_port: the network port on which to listen for DHT node requests
@param known_dht_nodes: a list of (ip_address, dht_port) which will be used to join the DHT network @param known_dht_nodes: a list of (ip_address, dht_port) which will be used to join the DHT network
""" """
self.session = LBRYSession(blob_manager_class=TempBlobManager,
stream_info_manager_class=DBLiveStreamMetadataManager, self.session = LBRYSession(blob_manager_class=blob_manager_class,
stream_info_manager_class=stream_info_manager_class,
dht_node_class=Node, dht_node_port=dht_node_port, known_dht_nodes=known_dht_nodes, dht_node_class=Node, dht_node_port=dht_node_port, known_dht_nodes=known_dht_nodes,
use_upnp=False) use_upnp=False)
self.payment_rate_manager = BaseLiveStreamPaymentRateManager() self.payment_rate_manager = BaseLiveStreamPaymentRateManager()