Hi,
I noticed that there are some duplicated codes in pgoutput_change() functionwhich can be simplified, and here is an attempt to do that.
Best Regards,Hou Zhijie