markLoaded indicates that topic subscribers have been loaded into memory.
()
| 3727 | |
| 3728 | // markLoaded indicates that topic subscribers have been loaded into memory. |
| 3729 | func (t *Topic) markLoaded() { |
| 3730 | t.statusChangeBits(topicStatusLoaded, true) |
| 3731 | } |
| 3732 | |
| 3733 | // markPaused pauses or unpauses the topic. When the topic is paused all |
| 3734 | // messages are rejected. |
no test coverage detected