Method map

src/react/observable.py:74–75 · view source on GitHub ↗

(self, map_function)

Source from the content-addressed store, hash-verified

72	return _TimeBufferedPipe(self, period_millis, aggregate_function)
73
74	def map(self, map_function):
75	return _MappedPipe(self, map_function)
76
77	def replay(self):
78	return _ReplayPipe(self)

test_map_single_updateMethod · 0.80

test_map_multiple_updatesMethod · 0.80

test_map_multiple_observers_single_updateMethod · 0.80

test_map_multiple_updates_late_subscriptionMethod · 0.80

test_pipe_replay_map_multiple_updates_late_subscriptionMethod · 0.80

test_map_closeMethod · 0.80

test_map_close_only_subscriptionMethod · 0.80

test_map_close_late_subscriptionMethod · 0.80

test_map_wait_closeMethod · 0.80

test_prohibit_piped_modificationsMethod · 0.80

test_map_read_until_closedMethod · 0.80

startMethod · 0.80

_MappedPipeClass · 0.85

test_map_single_updateMethod · 0.64

test_map_multiple_updatesMethod · 0.64

test_map_multiple_observers_single_updateMethod · 0.64

test_map_multiple_updates_late_subscriptionMethod · 0.64

test_pipe_replay_map_multiple_updates_late_subscriptionMethod · 0.64

test_map_closeMethod · 0.64

test_map_close_only_subscriptionMethod · 0.64

test_map_close_late_subscriptionMethod · 0.64

test_map_wait_closeMethod · 0.64

test_prohibit_piped_modificationsMethod · 0.64

test_map_read_until_closedMethod · 0.64