[rstream] subscribeTopic and transformTopic return incorrect type and incorrect values

[miraklez]

This exemple use a MQTT Broker to stream temperature from all sensors in a main stream, based on topic value.

type Event = { topic: string, value: number }
const main = pubsub({topic: (e: Event) => e.topic });

if i use subscribeTopic and xform to get only the value data

const outside = main.subscribeTopic('outside', { xform: map((e) => e.value)});
const room = main.subscribeTopic('room', { xform: map((e) => e.value) });
outside.subscribe(trace('outside'));
room.subscribe(trace('room'));

results

outside { topic: 'outside', value: 11 }
room { topic: 'room', value: 17 }
outside { topic: 'outside', value: 11 }
room { topic: 'room', value: 17 }

xform seems to not be applied at all but type for outside and room is correct ISubscription<Event, number>

but if i use transformTopic

const outside = main.transformTopic('outside', map((e) => e.value));
const room = main.transformTopic('room', map((e) => e.value));
outside.subscribe(trace('outside'));
room.subscribe(trace('room'));

results

outside 12
room 17
outside 12

it's the opposite.
i have correct values using trace but type for outside and room is incorrect ISubscription<Event, Event> instead of ISubscription<Event, number>

Using "@thi.ng/rstream": "^6.0.8",

Any pointers?

[postspectacular]

Hi @miraklez - am moving house this week and alas can't look into this right now. will get back to you asap (next week some time)