--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/commsfwsupport/commselements/NetSubscribe/INC/NetSubscriber.h	Thu Dec 17 09:22:25 2009 +0200
@@ -0,0 +1,168 @@
+// Copyright (c) 2004-2009 Nokia Corporation and/or its subsidiary(-ies).
+// All rights reserved.
+// This component and the accompanying materials are made available
+// under the terms of "Eclipse Public License v1.0"
+// which accompanies this distribution, and is available
+// at the URL "http://www.eclipse.org/legal/epl-v10.html".
+//
+// Initial Contributors:
+// Nokia Corporation - initial contribution.
+//
+// Contributors:
+//
+// Description:
+//
+
+/**
+ @file
+ @internalComponent
+*/
+
+
+#ifndef __NET_SUBSCRIBER_H__
+#define __NET_SUBSCRIBER_H__
+
+#include <e32base.h>
+#include <e32std.h>
+#include "NetSubscribe.h"
+#include "NetSignalEvent.h"
+
+namespace NetSubscribe
+{
+
+class TEventClientData 
+/**
+ * A client's subscribtion data. Class takes event data class + event id + signal
+ * handler. It's up to the type of subscription as to what transport layer & signal type
+ * is being used 
+ * e.g. signal types are as follows - public/subscribe, Active Object, request status,..
+ * transport layers - message queue, client/server, RProperty,...
+ *
+ * @see TEvent
+ * @see TSignalHandler
+ * @internalComponent
+ */
+	{
+	friend class TEventDataArray;
+	
+public:
+	TEventClientData( TEventBase& aEvent ) :
+		iEvent(aEvent)
+		{
+		}
+
+	void SignalL( const Meta::SMetaData* aData )
+		{
+		(Event()->iHandler)( Event()->iThis, aData );
+		};
+	void SignalErrorL( TInt aError );
+
+	TEvent* Event() const
+		{
+		return static_cast<TEvent*>(&iEvent);
+		}
+		
+protected:
+	TEventBase& iEvent;
+	};
+
+class TEventDataArray : public RArray<TEventClientData>
+	{
+public:
+	~TEventDataArray()
+		{
+		Close();
+		}
+	TInt Find( const TEventBase* aEvent );
+	TInt RegisterL( const TEventClientData& aData );
+	TInt DeRegister( const TEventBase* aEvent );
+	void DispatchL( const Meta::SMetaData* aData, TInt aErr );
+	};
+
+class XSignal
+/**
+ * The class abstracts physical signal source (active abject, status request,...)
+ * The class is owned by CNetSubscribe::iSignals and represents a signal that can have registered
+ * multiple client handlers
+ *
+ * @see TEvent
+ * @see TSignalHandler
+ * @see TSubscribtionData
+ * @internalComponent
+ */
+	{
+	public:
+		virtual ~XSignal();
+		/*
+		called by the specific signal handler to catch the event and demarshal data 
+		before forwarding call to the client.
+		*/
+//		virtual void SignalL() = 0; //not needed at the moment see the commend above the
+//CSignalActive declaration
+		/**
+		called by CNetSubscribe when deregistering event returns number of events(callbacks) still
+		registered for the signal.
+		*/
+		TInt DeRegisterClient(TEventBase* aEvent)
+			{
+			return iData.DeRegister(aEvent);
+			}
+		/**
+		called by CNetSubscribe when registering event returns number of events(callbacks)
+		registered for the signal.
+		*/
+		TInt RegisterClientL( TEventClientData& aData )
+			{
+			iData.RegisterL( aData );
+			return iData.Count();
+			}
+
+		const SSignalId& GetSignalId() const
+			{
+			return iSignalId;
+			}
+
+	protected:
+		XSignal(const SSignalId& aSignalId) :
+			iSignalId(aSignalId)
+			{
+			}
+
+	protected:
+		const SSignalId iSignalId;
+		TEventDataArray iData;
+	};
+
+//the class layout in NetSubscriber is missing an abstarction of dispatcher at the moment.
+//(the same way as a signal is abstracted by SSignal class). Therefore the cocncrete signal class
+//(e.g ~CPSSignal) must be aware of underlying method of capturing the signal (e.g this class).
+//The dispatcher abstraction should be added as new concrete signals & transport will appear.
+class CSignalActive : public CActive, public XSignal
+/**
+ * class catches a signal raised by active scheduler framework
+ *
+ * @see TEvent
+ * @see TSignalHandler
+ * @see TSubscribtionData
+ * @internalComponent
+ */
+	{
+public:
+	CSignalActive(const SSignalId& iSignalId) :
+		XSignal(iSignalId),
+		CActive(EPriorityNormal)
+		{
+		CActiveScheduler::Add(this);
+		}
+
+protected:
+//	virtual void RunL();
+	
+   virtual TInt RunError(TInt aError);
+	};
+
+} // namespace NetSubscribe
+
+	
+#endif // __NET_SUBSCRIBER_H__
+