Changing the source of streams doesn't update Stream.registry correctly.

[ruoyu0088]

Here is an example:

import holoviews as hv
from holoviews import opts, streams

def func1(x, y):
    x = x or 0
    y = y or 0
    return hv.Points(([x], [y])).opts(color="red", size=10)

def func2(x, y):
    x = x or 0
    y = y or 0
    return hv.Points(([x], [y])).opts(color="green", size=10)
    
stream1 = streams.PointerXY(source=None)
stream2 = streams.PointerXY(source=None)

d1 = hv.DynamicMap(func1, streams=[stream1])    
d2 = hv.DynamicMap(func2, streams=[stream2])

print(streams.Stream.registry[d1], streams.Stream.registry[d2])
stream1.source = d2
stream2.source = d1
print(streams.Stream.registry[d1], streams.Stream.registry[d2])

the output is

[PointerXY(x=None,y=None)] [PointerXY(x=None,y=None)]
[PointerXY(x=None,y=None), PointerXY(x=None,y=None)] [PointerXY(x=None,y=None), PointerXY(x=None,y=None)]

after changing the source, both the streams have been registered to both the DynamicMap objects. Mouse moving in one of the plot will cause the two points move. Because of this problem, I cannot make two plots that link the stream to each other.

It seems that it is a bug in the setter of source property. if self.source should be if self.source is not None. bool(d1) returns False because len(d1)==0.

    @source.setter
    def source(self, source):
        if self.source:  #--> if self.source is not None
            source_list = self.registry[self.source]
            if self in source_list:
                source_list.remove(self)

        if source is None:
            self._source = None
            return

        self._source = weakref.ref(source)
        if source in self.registry:
            self.registry[source].append(self)
        else:
            self.registry[source] = [self]

[philippjfr]

Yes, just encountered this bug myself. Could you submit a PR or should I?

[github-actions]

This issue has been automatically locked since there has not been any recent activity after it was closed. Please open a new issue for related bugs.