feat: commenting

This commit is contained in:
Swann
2019-07-23 18:44:17 +02:00
parent 760ba48349
commit 2f30b1ffd3
3 changed files with 10 additions and 9 deletions

View File

@ -71,7 +71,7 @@ class ReplicatedDataFactory(object):
class ReplicatedDatablock(object): class ReplicatedDatablock(object):
""" """
Datablock used for replication Datablock definition used for replication
""" """
uuid = None # uuid used as key (string) uuid = None # uuid used as key (string)
pointer = None # dcc data ref (DCC type) pointer = None # dcc data ref (DCC type)
@ -182,6 +182,7 @@ class ReplicatedDatablock(object):
""" """
raise NotImplementedError raise NotImplementedError
def __repr__(self): def __repr__(self):
return "{uuid} - owner: {owner} - type: {type}".format( return "{uuid} - owner: {owner} - type: {type}".format(
uuid=self.uuid, uuid=self.uuid,

View File

@ -68,13 +68,6 @@ class Client(object):
else: else:
raise TypeError("Type not supported") raise TypeError("Type not supported")
def pull(self,object=None):
"""
Asynchonous pull
Here we want to pull all waiting changes and apply them
"""
pass
def unregister(self,object_uuid,clean=False): def unregister(self,object_uuid,clean=False):
""" """
Unregister for replication the given Unregister for replication the given
@ -90,6 +83,12 @@ class Client(object):
else: else:
raise KeyError("Cannot unregister key") raise KeyError("Cannot unregister key")
def pull(self,object=None):
"""
Asynchonous pull
Here we want to pull all waiting changes and apply them
"""
pass
class ClientNetService(threading.Thread): class ClientNetService(threading.Thread):
def __init__(self,store_reference=None, factory=None,id="default"): def __init__(self,store_reference=None, factory=None,id="default"):

View File

@ -26,6 +26,7 @@ class RepSampleData(ReplicatedDatablock):
return pickle.loads(data) return pickle.loads(data)
def dump(self): def dump(self):
import json import json
output = {} output = {}