unpause_message

Description:

public void unpause_message (Message msg)

Resumes I/O on msg.

Use this to resume after calling pause_message, or after adding a new chunk to a chunked response.

I/O won't actually resume until you return to the main loop.

This must only be called on Messages which were created by the Server and are currently doing I/O, such as those passed into a ServerCallback or emitted in a request_read signal.

Example: Simple server, async:

public class NoodleSoupServer : Soup.Server {
	private int access_counter = 0;

	public NoodleSoupServer () {
		assert (this != null);

		// Links:
		//   http://localhost:8088/*
		this.add_handler (null, default_handler);
	}

	private static void default_handler (Soup.Server server, Soup.Message msg, string path, GLib.HashTable? query, Soup.ClientContext client) {
		unowned NoodleSoupServer self = server as NoodleSoupServer;

		uint id = self.access_counter++;
		print ("Default handler start (%u)\n", id);

		// Simulate asynchronous input / time consuming operations:
		// See GLib.IOSchedulerJob for time consuming operations
		Timeout.add_seconds (0, () => {
			string html_head = "<head><title>Index</title></head>";
			string html_body = "<body><h1>Index:</h1></body>";
			msg.set_response ("text/html", Soup.MemoryUse.COPY, "<html>%s%s</html>".printf (html_head, html_body).data);

			// Resumes HTTP I/O on msg:
			self.unpause_message (msg);
			print ("Default handler end (%u)\n", id);
			return false;
		}, Priority.DEFAULT);

		// Pauses HTTP I/O on msg:
		self.pause_message (msg);
	}

	public static int main (string[] args) {
		try {
			int port = 8088;

			MainLoop loop = new MainLoop ();

			NoodleSoupServer server = new NoodleSoupServer ();
			server.listen_all (port, 0);

			loop.run ();
		} catch (Error e) {
			print ("Error: %s\n", e.message);
		}
		return 0;
	}
}

valac --pkg libsoup-2.4 simple-server-async-new.vala

Parameters:

this	a Server
msg	a Message associated with this.