[PR #736] feat: add publish and getpubsub for streaming #1851

New issue

Open

opened 2026-03-07 22:13:33 +03:00 by kerem · 0 comments

kerem commented

2026-03-07 22:13:33 +03:00

Owner

📋 Pull Request Information

Original PR: https://github.com/hibiken/asynq/pull/736
Author: @FogDong
Created: 9/7/2023
Status: 🔄 Open

Base: master ← Head: feat-streaming

📝 Commits (1)

40df09c feat: add publish and getpubsub for streaming

📊 Changes

5 files changed (+49 additions, -8 deletions)

View changed files

📝 asynq.go (+17 -6)
📝 inspector.go (+9 -1)
📝 internal/base/base.go (+2 -0)
📝 internal/rdb/rdb.go (+11 -0)
📝 internal/testbroker/testbroker.go (+10 -1)

📄 Description

Fix #437

This PR adds publish and getPubSub so that users can use publish to stream messages and use getPubSub to receive.

_{🔄 This issue represents a GitHub Pull Request. It cannot be merged through Gitea due to API limitations.}

## 📋 Pull Request Information **Original PR:** https://github.com/hibiken/asynq/pull/736 **Author:** [@FogDong](https://github.com/FogDong) **Created:** 9/7/2023 **Status:** 🔄 Open **Base:** `master` ← **Head:** `feat-streaming` --- ### 📝 Commits (1) - [`40df09c`](https://github.com/hibiken/asynq/commit/40df09cb367b7eea1a51bf9a184ee9ffac211f53) feat: add publish and getpubsub for streaming ### 📊 Changes **5 files changed** (+49 additions, -8 deletions) <details> <summary>View changed files</summary> 📝 `asynq.go` (+17 -6) 📝 `inspector.go` (+9 -1) 📝 `internal/base/base.go` (+2 -0) 📝 `internal/rdb/rdb.go` (+11 -0) 📝 `internal/testbroker/testbroker.go` (+10 -1) </details> ### 📄 Description Fix #437 This PR adds `publish` and `getPubSub` so that users can use `publish` to stream messages and use `getPubSub` to receive. --- <sub>🔄 This issue represents a GitHub Pull Request. It cannot be merged through Gitea due to API limitations.</sub>

kerem added the

pull-request

label

2026-03-07 22:13:33 +03:00

No milestone

No project

No assignees

1 participant

Notifications

Due date

The due date is invalid or out of range. Please use the format "yyyy-mm-dd".

No due date set.

Dependencies

No dependencies set.

Reference

starred/asynq#1851

No description provided.

Rows
Columns