32 * The socket reader request interface. |
32 * The socket reader request interface. |
33 */ |
33 */ |
34 |
34 |
35 class CMSRPWriter : public CActive, public MMSRPWriter |
35 class CMSRPWriter : public CActive, public MMSRPWriter |
36 { |
36 { |
37 public: |
37 public: |
|
38 |
|
39 // Constructors and destructor |
|
40 static MMSRPWriter* NewL(RSocket& aSocket, MMSRPWriterErrorObserver& aConnection ); |
|
41 virtual ~CMSRPWriter(); |
38 |
42 |
39 // Constructors and destructor |
43 public: // from MMSRPWriter |
40 static MMSRPWriter* NewL(RSocket& aSocket, MMSRPWriterErrorObserver& aConnection ); |
44 void RequestSendL(MMSRPWriterObserver& aMsg); |
41 virtual ~CMSRPWriter(); |
45 void CancelSendingL( const MMSRPWriterObserver* aMsg ); |
42 |
46 |
43 virtual void RequestSendL(MMSRPWriterObserver& aMsg); |
47 protected: // from CActive |
44 |
48 void DoCancel(); |
45 protected: // from CActive |
49 void RunL(); |
46 void DoCancel(); |
50 TInt RunError(TInt aError); |
47 void RunL(); |
51 |
48 TInt RunError(TInt aError); |
52 private: |
|
53 CMSRPWriter(RSocket& aSocket, MMSRPWriterErrorObserver& aConnection); |
|
54 void ConstructL(); |
|
55 void SendL(); |
49 |
56 |
50 private: |
57 private: // data |
51 CMSRPWriter(RSocket& aSocket, MMSRPWriterErrorObserver& aConnection); |
58 MMSRPWriterErrorObserver& iConnection; |
52 void ConstructL(); |
59 RSocket& iSocket; |
53 void SendL(); |
60 RPointerArray<MMSRPWriterObserver> iSendQueue; |
54 |
61 TBool iWriteIssued; |
55 private: // data |
|
56 MMSRPWriterErrorObserver& iConnection; |
|
57 RSocket& iSocket; |
|
58 RPointerArray<MMSRPWriterObserver> iSendQueue; |
|
59 TBool iWriteIssued; |
|
60 }; |
62 }; |
61 |
63 |
62 #endif // CMSRPWRITER_H |
64 #endif // CMSRPWRITER_H |
63 |
65 |
64 // End of file |
66 // End of file |