Skip to content

Commit cb434a2

Browse files
committed
Fix Notification example in readme
[resolves #192]
1 parent 112ed97 commit cb434a2

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

README.md

+3-3
Original file line numberDiff line numberDiff line change
@@ -165,13 +165,13 @@ For Listen/Notify, two actors are involved: The sender (notify) and the receiver
165165
to illustrate how they work together:
166166

167167
```java
168-
Connection sender = …;
169-
Connection receiver = …;
168+
PostgresqlConnection sender = …;
169+
PostgresqlConnection receiver = …;
170170

171171
Flux<Notification> listen = receiver.createStatement("LISTEN mymessage")
172172
.execute()
173173
.flatMap(PostgresqlResult::getRowsUpdated)
174-
.thenMany(listen.getNotifications());
174+
.thenMany(receiver.getNotifications());
175175

176176
Mono<Void> notify = sender.createStatement("NOTIFY mymessage, 'Hello World'")
177177
.execute()

0 commit comments

Comments
 (0)